public interface XnioIoFactory
Modifier and Type | Method and Description |
---|---|
IoFuture<MessageConnection> |
acceptMessageConnection(java.net.SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Accept a message connection at a destination address.
|
IoFuture<StreamConnection> |
acceptStreamConnection(java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Accept a stream connection at a destination address.
|
ChannelPipe<StreamChannel,StreamChannel> |
createFullDuplexPipe()
Create a two-way stream pipe.
|
ChannelPipe<StreamConnection,StreamConnection> |
createFullDuplexPipeConnection()
Create a two-way stream pipe.
|
ChannelPipe<StreamConnection,StreamConnection> |
createFullDuplexPipeConnection(XnioIoFactory peer)
Create a two-way stream pipe.
|
ChannelPipe<StreamSourceChannel,StreamSinkChannel> |
createHalfDuplexPipe()
Create a one-way stream pipe.
|
ChannelPipe<StreamSourceChannel,StreamSinkChannel> |
createHalfDuplexPipe(XnioIoFactory peer)
Create a one-way stream pipe.
|
IoFuture<MessageConnection> |
openMessageConnection(java.net.SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
OptionMap optionMap)
Connect to a remote message server.
|
IoFuture<StreamConnection> |
openStreamConnection(java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Connect to a remote stream server.
|
IoFuture<StreamConnection> |
openStreamConnection(java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
OptionMap optionMap)
Connect to a remote stream server.
|
IoFuture<StreamConnection> |
openStreamConnection(java.net.SocketAddress bindAddress,
java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Connect to a remote stream server.
|
IoFuture<StreamConnection> openStreamConnection(java.net.SocketAddress destination, ChannelListener<? super StreamConnection> openListener, OptionMap optionMap)
IoFuture
, and vice-versa.destination
- the destination addressopenListener
- the listener which will be notified when the channel is open, or null
for noneoptionMap
- the option mapIoFuture<StreamConnection> openStreamConnection(java.net.SocketAddress destination, ChannelListener<? super StreamConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap)
IoFuture
, and vice-versa.destination
- the destination addressopenListener
- the listener which will be notified when the channel is open, or null
for nonebindListener
- the listener which will be notified when the channel is bound, or null
for noneoptionMap
- the option mapIoFuture<StreamConnection> openStreamConnection(java.net.SocketAddress bindAddress, java.net.SocketAddress destination, ChannelListener<? super StreamConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap)
IoFuture
, and vice-versa.bindAddress
- the local address to bind todestination
- the destination addressopenListener
- the listener which will be notified when the channel is open, or null
for nonebindListener
- the listener which will be notified when the channel is bound, or null
for noneoptionMap
- the option mapIoFuture<StreamConnection> acceptStreamConnection(java.net.SocketAddress destination, ChannelListener<? super StreamConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap)
destination
- the destination (bind) addressopenListener
- the listener which will be notified when the channel is open, or null
for nonebindListener
- the listener which will be notified when the acceptor is bound, or null
for noneoptionMap
- the option mapIoFuture<MessageConnection> openMessageConnection(java.net.SocketAddress destination, ChannelListener<? super MessageConnection> openListener, OptionMap optionMap)
IoFuture
, and vice-versa.destination
- the destination addressopenListener
- the listener which will be notified when the channel is open, or null
for noneoptionMap
- the option mapIoFuture<MessageConnection> acceptMessageConnection(java.net.SocketAddress destination, ChannelListener<? super MessageConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap)
IoFuture
, and vice-versa.destination
- the destination (bind) addressopenListener
- the listener which will be notified when the channel is open, or null
for nonebindListener
- the listener which will be notified when the acceptor is bound, or null
for noneoptionMap
- the option mapChannelPipe<StreamChannel,StreamChannel> createFullDuplexPipe() throws java.io.IOException
java.io.IOException
- if the pipe could not be createdChannelPipe<StreamConnection,StreamConnection> createFullDuplexPipeConnection() throws java.io.IOException
java.io.IOException
- if the pipe could not be createdChannelPipe<StreamSourceChannel,StreamSinkChannel> createHalfDuplexPipe() throws java.io.IOException
java.io.IOException
- if the pipe could not be createdChannelPipe<StreamConnection,StreamConnection> createFullDuplexPipeConnection(XnioIoFactory peer) throws java.io.IOException
peer
- the peer to use for controlling the remote (right) sidejava.io.IOException
- if the pipe could not be createdChannelPipe<StreamSourceChannel,StreamSinkChannel> createHalfDuplexPipe(XnioIoFactory peer) throws java.io.IOException
peer
- the peer to use for the sink (right) sidejava.io.IOException
- if the pipe could not be createdCopyright © 2016 JBoss, a division of Red Hat, Inc.