Package | Description |
---|---|
io.undertow.client | |
io.undertow.client.http2 | |
io.undertow.io | |
io.undertow.protocols.ajp | |
io.undertow.protocols.http2 | |
io.undertow.protocols.ssl | |
io.undertow.server | |
io.undertow.server.handlers | |
io.undertow.server.handlers.sse | |
io.undertow.server.protocol.ajp | |
io.undertow.server.protocol.framed | |
io.undertow.server.protocol.http | |
io.undertow.server.protocol.http2 | |
io.undertow.server.protocol.proxy | |
io.undertow.util | |
io.undertow.websockets.core | |
org.xnio |
The main API package for XNIO.
|
org.xnio.channels |
The core XNIO channel API.
|
org.xnio.conduits |
The XNIO conduit SPI.
|
org.xnio.http | |
org.xnio.ssl |
Utility classes for using and implementing SSL within XNIO providers.
|
Modifier and Type | Method and Description |
---|---|
ChannelListener<SslConnection> |
ALPNClientSelector.ALPNProtocol.getSelected() |
Modifier and Type | Method and Description |
---|---|
void |
ClientConnection.addCloseListener(ChannelListener<ClientConnection> listener)
Adds a close listener, than will be invoked with the connection is closed
|
static void |
ALPNClientSelector.runAlpn(SslConnection sslConnection,
ChannelListener<SslConnection> fallback,
ClientCallback<ClientConnection> failedListener,
ALPNClientSelector.ALPNProtocol... details) |
Constructor and Description |
---|
ALPNProtocol(ChannelListener<SslConnection> selected,
String protocol) |
Modifier and Type | Method and Description |
---|---|
void |
Http2ClientConnection.addCloseListener(ChannelListener<ClientConnection> listener) |
Modifier and Type | Class and Description |
---|---|
class |
AsyncSenderImpl.TransferTask |
Modifier and Type | Method and Description |
---|---|
AjpClientRequestClientStreamSinkChannel |
AjpClientChannel.sendRequest(HttpString method,
String path,
HttpString protocol,
HeaderMap headers,
Attachable attachable,
ChannelListener<AjpClientRequestClientStreamSinkChannel> finishListener) |
void |
AjpClientResponseStreamSourceChannel.setFinishListener(ChannelListener<AjpClientResponseStreamSourceChannel> finishListener) |
Modifier and Type | Method and Description |
---|---|
ChannelListener<Http2StreamSourceChannel> |
Http2StreamSourceChannel.getCompletionListener() |
ChannelListener<Http2DataStreamSinkChannel> |
Http2DataStreamSinkChannel.getCompletionListener() |
Modifier and Type | Method and Description |
---|---|
void |
Http2DataStreamSinkChannel.setCompletionListener(ChannelListener<Http2DataStreamSinkChannel> completionListener) |
void |
Http2StreamSourceChannel.setCompletionListener(ChannelListener<Http2StreamSourceChannel> completionListener) |
Modifier and Type | Interface and Description |
---|---|
interface |
DelegateOpenListener
An open listener that handles being delegated to, e.g.
|
interface |
OpenListener
Interface that represents an open listener, aka a connector.
|
Modifier and Type | Method and Description |
---|---|
void |
ChannelUpgradeHandler.addProtocol(String productString,
ChannelListener<? super StreamConnection> openListener)
Add a protocol to this handler.
|
void |
ChannelUpgradeHandler.addProtocol(String productString,
ChannelListener<? super StreamConnection> openListener,
HttpUpgradeHandshake handshake)
Add a protocol to this handler.
|
void |
ChannelUpgradeHandler.removeProtocol(String productString,
ChannelListener<? super StreamConnection> openListener)
Remove a protocol from this handler.
|
Modifier and Type | Method and Description |
---|---|
void |
ServerSentEventConnection.addCloseTask(ChannelListener<ServerSentEventConnection> listener)
Adds a listener that will be invoked when the channel is closed
|
Modifier and Type | Class and Description |
---|---|
class |
AjpOpenListener |
Modifier and Type | Method and Description |
---|---|
void |
AbstractFramedChannel.addCloseTask(ChannelListener<C> task) |
void |
AbstractFramedStreamSourceChannel.addCloseTask(ChannelListener<R> channelListener) |
Modifier and Type | Class and Description |
---|---|
class |
AlpnOpenListener
Open listener adaptor for ALPN connections
|
class |
HttpOpenListener
Open listener for HTTP server.
|
Modifier and Type | Class and Description |
---|---|
class |
Http2OpenListener
Open listener for HTTP2 server
|
class |
Http2ReceiveListener
The recieve listener for a Http2 connection.
|
Modifier and Type | Class and Description |
---|---|
class |
ProxyProtocolOpenListener
Open listener for proxied connections
|
Modifier and Type | Class and Description |
---|---|
class |
StringReadChannelListener
Simple utility class for reading a string
|
class |
StringWriteChannelListener
A simple write listener that can be used to write out the contents of a String.
|
Modifier and Type | Method and Description |
---|---|
static <I extends StreamSourceChannel,O extends StreamSinkChannel> |
Transfer.initiateTransfer(I source,
O sink,
ChannelListener<? super I> sourceListener,
ChannelListener<? super O> sinkListener,
ChannelExceptionHandler<? super I> readExceptionHandler,
ChannelExceptionHandler<? super O> writeExceptionHandler,
ByteBufferPool pool)
Initiate a low-copy transfer between two stream channels.
|
static <I extends StreamSourceChannel,O extends StreamSinkChannel> |
Transfer.initiateTransfer(I source,
O sink,
ChannelListener<? super I> sourceListener,
ChannelListener<? super O> sinkListener,
ChannelExceptionHandler<? super I> readExceptionHandler,
ChannelExceptionHandler<? super O> writeExceptionHandler,
ByteBufferPool pool)
Initiate a low-copy transfer between two stream channels.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractReceiveListener
A receive listener that performs a callback when it receives a message
|
Modifier and Type | Method and Description |
---|---|
static <I extends StreamSourceChannel,O extends StreamSinkChannel> |
WebSocketUtils.initiateTransfer(I source,
O sink,
ChannelListener<? super I> sourceListener,
ChannelListener<? super O> sinkListener,
ChannelExceptionHandler<? super I> readExceptionHandler,
ChannelExceptionHandler<? super O> writeExceptionHandler,
ByteBufferPool pool)
Deprecated.
|
static <I extends StreamSourceChannel,O extends StreamSinkChannel> |
WebSocketUtils.initiateTransfer(I source,
O sink,
ChannelListener<? super I> sourceListener,
ChannelListener<? super O> sinkListener,
ChannelExceptionHandler<? super I> readExceptionHandler,
ChannelExceptionHandler<? super O> writeExceptionHandler,
ByteBufferPool pool)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
ChainedChannelListener<T extends Channel>
A channel listener that chains calls to a number of other channel listeners.
|
class |
DelegatingChannelListener<T extends Channel>
A base class for a channel listener which performs an action and then calls a delegate listener.
|
Modifier and Type | Method and Description |
---|---|
static ChannelListener<Channel> |
ChannelListeners.closingChannelListener()
Get a channel listener which closes the channel when notified.
|
static <T extends Channel> |
ChannelListeners.closingChannelListener(ChannelListener<T> delegate,
Closeable... resources)
Get a channel listener which closes the given resource when notified.
|
static <T extends Channel> |
ChannelListeners.closingChannelListener(ChannelListener<T> delegate,
Closeable resource)
Get a channel listener which closes the given resource when notified.
|
static ChannelListener<Channel> |
ChannelListeners.closingChannelListener(Closeable... resources)
Get a channel listener which closes the given resources when notified.
|
static ChannelListener<Channel> |
ChannelListeners.closingChannelListener(Closeable resource)
Get a channel listener which closes the given resource when notified.
|
static <T extends Channel> |
ChannelListeners.delegatingChannelListener(ChannelListener<? super T> delegate)
A delegating channel listener which passes an event to another listener of the same or a super type.
|
static <C extends Channel,T extends Channel> |
ChannelListeners.delegatingChannelListener(T channel,
ChannelListener.SimpleSetter<T> setter)
A delegating channel listener which passes an event to the listener stored in the given setter.
|
static <T extends StreamSourceChannel> |
ChannelListeners.drainListener(long bytes,
ChannelListener<? super T> finishListener,
ChannelExceptionHandler<? super T> exceptionHandler)
Create a channel listener which automatically drains the given number of bytes from the channel and then calls
a listener.
|
static <T extends Channel> |
ChannelListeners.executorChannelListener(ChannelListener<T> listener,
Executor executor)
Get a channel listener which executes a delegate channel listener via an executor.
|
static <T extends StreamSourceChannel> |
ChannelListeners.fileReceivingChannelListener(FileChannel target,
long position,
long count,
ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler)
A file-receiving channel listener.
|
static <T extends StreamSinkChannel> |
ChannelListeners.fileSendingChannelListener(FileChannel source,
long position,
long count,
ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler)
A file-sending channel listener.
|
static <T extends SuspendableWriteChannel> |
ChannelListeners.flushingChannelListener(ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler)
A flushing channel listener.
|
ChannelListener<? super T> |
ChannelListener.SimpleSetter.get()
Get the channel listener set on this setter.
|
ChannelListener<? super StreamConnection> |
StreamConnection.getCloseListener() |
ChannelListener<? super MessageConnection> |
MessageConnection.getCloseListener() |
static ChannelListener<Channel> |
ChannelListeners.nullChannelListener()
Get a channel listener which does nothing.
|
static <C extends ConnectedChannel> |
ChannelListeners.openListenerAdapter(ChannelListener<? super C> openListener)
Create an open listener adapter which automatically accepts connections and invokes an open listener.
|
static <T extends SuspendableReadChannel> |
ChannelListeners.readSuspendingChannelListener(ChannelListener<? super T> delegate)
A read-suspending channel listener.
|
static <T extends WritableMessageChannel> |
ChannelListeners.sendingChannelListener(Pooled<ByteBuffer> pooled,
ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler)
A sending channel listener.
|
static <T extends SuspendableWriteChannel> |
ChannelListeners.writeShutdownChannelListener(ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler)
A write shutdown channel listener.
|
static <T extends SuspendableWriteChannel> |
ChannelListeners.writeSuspendingChannelListener(ChannelListener<? super T> delegate)
A write-suspending channel listener.
|
static <T extends StreamSinkChannel> |
ChannelListeners.writingChannelListener(Pooled<ByteBuffer> pooled,
ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler)
A writing channel listener.
|
Modifier and Type | Method and Description |
---|---|
static <T extends Channel> |
IoUtils.channelListenerNotifier()
Get the notifier that invokes the channel listener given as an attachment.
|
Modifier and Type | Method and Description |
---|---|
IoFuture<? extends T> |
ChannelDestination.accept(ChannelListener<? super T> openListener,
ChannelListener<? super BoundChannel> bindListener)
Accept a connection.
|
IoFuture<? extends T> |
ChannelDestination.accept(ChannelListener<? super T> openListener,
ChannelListener<? super BoundChannel> bindListener)
Accept a connection.
|
IoFuture<ConnectedMessageChannel> |
XnioWorker.acceptDatagram(SocketAddress destination,
ChannelListener<? super ConnectedMessageChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Deprecated.
|
IoFuture<ConnectedMessageChannel> |
XnioWorker.acceptDatagram(SocketAddress destination,
ChannelListener<? super ConnectedMessageChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Deprecated.
|
protected IoFuture<MessageConnection> |
XnioIoThread.acceptLocalMessageConnection(LocalSocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to accept a local (UNIX domain) datagram connection.
|
protected IoFuture<MessageConnection> |
XnioIoThread.acceptLocalMessageConnection(LocalSocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to accept a local (UNIX domain) datagram connection.
|
protected IoFuture<StreamConnection> |
XnioIoThread.acceptLocalStreamConnection(LocalSocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to accept a local (UNIX domain) stream connection.
|
protected IoFuture<StreamConnection> |
XnioIoThread.acceptLocalStreamConnection(LocalSocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to accept a local (UNIX domain) stream connection.
|
IoFuture<MessageConnection> |
XnioIoFactory.acceptMessageConnection(SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Accept a message connection at a destination address.
|
IoFuture<MessageConnection> |
XnioIoFactory.acceptMessageConnection(SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Accept a message connection at a destination address.
|
IoFuture<MessageConnection> |
XnioWorker.acceptMessageConnection(SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<MessageConnection> |
XnioWorker.acceptMessageConnection(SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<MessageConnection> |
XnioIoThread.acceptMessageConnection(SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<MessageConnection> |
XnioIoThread.acceptMessageConnection(SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<ConnectedStreamChannel> |
XnioWorker.acceptStream(SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Deprecated.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.acceptStream(SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Deprecated.
|
IoFuture<StreamConnection> |
XnioIoFactory.acceptStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Accept a stream connection at a destination address.
|
IoFuture<StreamConnection> |
XnioIoFactory.acceptStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Accept a stream connection at a destination address.
|
IoFuture<StreamConnection> |
XnioWorker.acceptStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioWorker.acceptStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioIoThread.acceptStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioIoThread.acceptStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
protected IoFuture<StreamConnection> |
XnioIoThread.acceptTcpStreamConnection(InetSocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to accept a TCP connection.
|
protected IoFuture<StreamConnection> |
XnioIoThread.acceptTcpStreamConnection(InetSocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to accept a TCP connection.
|
static <T extends Channel> |
ChannelListeners.closingChannelListener(ChannelListener<T> delegate,
Closeable... resources)
Get a channel listener which closes the given resource when notified.
|
static <T extends Channel> |
ChannelListeners.closingChannelListener(ChannelListener<T> delegate,
Closeable resource)
Get a channel listener which closes the given resource when notified.
|
IoFuture<ConnectedMessageChannel> |
XnioWorker.connectDatagram(SocketAddress destination,
ChannelListener<? super ConnectedMessageChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Deprecated.
|
IoFuture<ConnectedMessageChannel> |
XnioWorker.connectDatagram(SocketAddress destination,
ChannelListener<? super ConnectedMessageChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Deprecated.
|
IoFuture<ConnectedMessageChannel> |
XnioWorker.connectDatagram(SocketAddress bindAddress,
SocketAddress destination,
ChannelListener<? super ConnectedMessageChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Deprecated.
|
IoFuture<ConnectedMessageChannel> |
XnioWorker.connectDatagram(SocketAddress bindAddress,
SocketAddress destination,
ChannelListener<? super ConnectedMessageChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Deprecated.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.connectStream(SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Deprecated.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.connectStream(SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Deprecated.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.connectStream(SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
OptionMap optionMap)
Deprecated.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.connectStream(SocketAddress bindAddress,
SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Deprecated.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.connectStream(SocketAddress bindAddress,
SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Deprecated.
|
protected AcceptingChannel<StreamConnection> |
XnioWorker.createLocalStreamConnectionServer(LocalSocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<StreamConnection>> acceptListener,
OptionMap optionMap)
Implementation helper method to create a UNIX domain stream server.
|
void |
XnioWorker.createOneWayPipe(ChannelListener<? super StreamSourceChannel> sourceListener,
ChannelListener<? super StreamSinkChannel> sinkListener,
OptionMap optionMap)
Deprecated.
Users should prefer the simpler
XnioWorker.createHalfDuplexPipe() instead. |
void |
XnioWorker.createOneWayPipe(ChannelListener<? super StreamSourceChannel> sourceListener,
ChannelListener<? super StreamSinkChannel> sinkListener,
OptionMap optionMap)
Deprecated.
Users should prefer the simpler
XnioWorker.createHalfDuplexPipe() instead. |
void |
XnioWorker.createPipe(ChannelListener<? super StreamChannel> leftOpenListener,
ChannelListener<? super StreamChannel> rightOpenListener,
OptionMap optionMap)
Deprecated.
Users should prefer the simpler
XnioWorker.createFullDuplexPipe() instead. |
void |
XnioWorker.createPipe(ChannelListener<? super StreamChannel> leftOpenListener,
ChannelListener<? super StreamChannel> rightOpenListener,
OptionMap optionMap)
Deprecated.
Users should prefer the simpler
XnioWorker.createFullDuplexPipe() instead. |
AcceptingChannel<StreamConnection> |
XnioWorker.createStreamConnectionServer(SocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<StreamConnection>> acceptListener,
OptionMap optionMap)
Create a stream server, for TCP or UNIX domain servers.
|
AcceptingChannel<? extends ConnectedStreamChannel> |
XnioWorker.createStreamServer(SocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<ConnectedStreamChannel>> acceptListener,
OptionMap optionMap)
Deprecated.
|
protected AcceptingChannel<StreamConnection> |
XnioWorker.createTcpConnectionServer(InetSocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<StreamConnection>> acceptListener,
OptionMap optionMap)
Implementation helper method to create a TCP stream server.
|
MulticastMessageChannel |
XnioWorker.createUdpServer(InetSocketAddress bindAddress,
ChannelListener<? super MulticastMessageChannel> bindListener,
OptionMap optionMap)
Create a UDP server.
|
static <T extends Channel> |
ChannelListeners.delegatingChannelListener(ChannelListener<? super T> delegate)
A delegating channel listener which passes an event to another listener of the same or a super type.
|
static <T extends StreamSourceChannel> |
ChannelListeners.drainListener(long bytes,
ChannelListener<? super T> finishListener,
ChannelExceptionHandler<? super T> exceptionHandler)
Create a channel listener which automatically drains the given number of bytes from the channel and then calls
a listener.
|
static <T extends Channel> |
ChannelListeners.executorChannelListener(ChannelListener<T> listener,
Executor executor)
Get a channel listener which executes a delegate channel listener via an executor.
|
static <T extends StreamSourceChannel> |
ChannelListeners.fileReceivingChannelListener(FileChannel target,
long position,
long count,
ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler)
A file-receiving channel listener.
|
static <T extends StreamSinkChannel> |
ChannelListeners.fileSendingChannelListener(FileChannel source,
long position,
long count,
ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler)
A file-sending channel listener.
|
static <T extends SuspendableWriteChannel> |
ChannelListeners.flushingChannelListener(ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler)
A flushing channel listener.
|
static <T extends Channel> |
ChannelListeners.getChannelListenerTask(T channel,
ChannelListener<? super T> channelListener)
Get a task which invokes the given channel listener on the given channel.
|
static <I extends StreamSourceChannel,O extends StreamSinkChannel> |
ChannelListeners.initiateTransfer(long count,
I source,
O sink,
ChannelListener<? super I> sourceListener,
ChannelListener<? super O> sinkListener,
ChannelExceptionHandler<? super I> readExceptionHandler,
ChannelExceptionHandler<? super O> writeExceptionHandler,
Pool<ByteBuffer> pool)
Initiate a low-copy transfer between two stream channels.
|
static <I extends StreamSourceChannel,O extends StreamSinkChannel> |
ChannelListeners.initiateTransfer(long count,
I source,
O sink,
ChannelListener<? super I> sourceListener,
ChannelListener<? super O> sinkListener,
ChannelExceptionHandler<? super I> readExceptionHandler,
ChannelExceptionHandler<? super O> writeExceptionHandler,
Pool<ByteBuffer> pool)
Initiate a low-copy transfer between two stream channels.
|
static <T extends Channel> |
ChannelListeners.invokeChannelListener(Executor executor,
T channel,
ChannelListener<? super T> channelListener)
Invoke a channel listener on a given channel, logging any errors, using the given executor.
|
static <T extends Channel> |
ChannelListeners.invokeChannelListener(T channel,
ChannelListener<? super T> channelListener)
Invoke a channel listener on a given channel, logging any errors.
|
IoFuture<T> |
ChannelSource.open(ChannelListener<? super T> openListener)
Open a channel.
|
static <C extends ConnectedChannel> |
ChannelListeners.openListenerAdapter(ChannelListener<? super C> openListener)
Create an open listener adapter which automatically accepts connections and invokes an open listener.
|
protected IoFuture<MessageConnection> |
XnioIoThread.openLocalMessageConnection(LocalSocketAddress bindAddress,
LocalSocketAddress destinationAddress,
ChannelListener<? super MessageConnection> openListener,
OptionMap optionMap)
Implementation helper method to connect to a local (UNIX domain) server.
|
protected IoFuture<StreamConnection> |
XnioIoThread.openLocalStreamConnection(LocalSocketAddress bindAddress,
LocalSocketAddress destinationAddress,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to connect to a local (UNIX domain) server.
|
protected IoFuture<StreamConnection> |
XnioIoThread.openLocalStreamConnection(LocalSocketAddress bindAddress,
LocalSocketAddress destinationAddress,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to connect to a local (UNIX domain) server.
|
IoFuture<MessageConnection> |
XnioIoFactory.openMessageConnection(SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
OptionMap optionMap)
Connect to a remote message server.
|
IoFuture<MessageConnection> |
XnioWorker.openMessageConnection(SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
OptionMap optionMap) |
IoFuture<MessageConnection> |
XnioIoThread.openMessageConnection(SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioIoFactory.openStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Connect to a remote stream server.
|
IoFuture<StreamConnection> |
XnioIoFactory.openStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Connect to a remote stream server.
|
IoFuture<StreamConnection> |
XnioWorker.openStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioWorker.openStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioIoThread.openStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioIoThread.openStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioIoFactory.openStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
OptionMap optionMap)
Connect to a remote stream server.
|
IoFuture<StreamConnection> |
XnioWorker.openStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioIoThread.openStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioIoFactory.openStreamConnection(SocketAddress bindAddress,
SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Connect to a remote stream server.
|
IoFuture<StreamConnection> |
XnioIoFactory.openStreamConnection(SocketAddress bindAddress,
SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Connect to a remote stream server.
|
IoFuture<StreamConnection> |
XnioWorker.openStreamConnection(SocketAddress bindAddress,
SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioWorker.openStreamConnection(SocketAddress bindAddress,
SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioIoThread.openStreamConnection(SocketAddress bindAddress,
SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioIoThread.openStreamConnection(SocketAddress bindAddress,
SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
protected IoFuture<StreamConnection> |
XnioIoThread.openTcpStreamConnection(InetSocketAddress bindAddress,
InetSocketAddress destinationAddress,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to connect to a TCP server.
|
protected IoFuture<StreamConnection> |
XnioIoThread.openTcpStreamConnection(InetSocketAddress bindAddress,
InetSocketAddress destinationAddress,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Implementation helper method to connect to a TCP server.
|
static <T extends SuspendableReadChannel> |
ChannelListeners.readSuspendingChannelListener(ChannelListener<? super T> delegate)
A read-suspending channel listener.
|
static <T extends WritableMessageChannel> |
ChannelListeners.sendingChannelListener(Pooled<ByteBuffer> pooled,
ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler)
A sending channel listener.
|
void |
ChannelListener.Setter.set(ChannelListener<? super T> listener)
Set the listener, or
null to ignore the associated event type. |
void |
ChannelListener.SimpleSetter.set(ChannelListener<? super T> listener)
Set the listener, or
null to ignore the associated event type. |
void |
MessageConnection.setCloseListener(ChannelListener<? super MessageConnection> listener) |
void |
StreamConnection.setCloseListener(ChannelListener<? super StreamConnection> listener) |
static <T extends SuspendableWriteChannel> |
ChannelListeners.writeShutdownChannelListener(ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler)
A write shutdown channel listener.
|
static <T extends SuspendableWriteChannel> |
ChannelListeners.writeSuspendingChannelListener(ChannelListener<? super T> delegate)
A write-suspending channel listener.
|
static <T extends StreamSinkChannel> |
ChannelListeners.writingChannelListener(Pooled<ByteBuffer> pooled,
ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler)
A writing channel listener.
|
Modifier and Type | Method and Description |
---|---|
static <T extends Channel> |
ChannelListeners.getSetter(AtomicReference<ChannelListener<? super T>> atomicReference)
Get a setter based on an atomic reference.
|
static <T extends Channel,C> |
ChannelListeners.getSetter(C channel,
AtomicReferenceFieldUpdater<C,ChannelListener> updater)
Deprecated.
Not recommended as a security manager will enforce unreasonable restrictions on the updater.
|
Constructor and Description |
---|
ChainedChannelListener(ChannelListener<? super T>... listeners)
Construct a new instance.
|
DelegatingChannelListener(ChannelListener<? super T> next)
Construct a new instance.
|
Modifier and Type | Method and Description |
---|---|
ChannelListener<? super C> |
AcceptListenerSettable.getAcceptListener()
Get the accept listener.
|
ChannelListener<? super NullStreamSinkChannel> |
NullStreamSinkChannel.getCloseListener() |
ChannelListener<? super SplitStreamSourceChannel> |
SplitStreamSourceChannel.getCloseListener() |
ChannelListener<? super C> |
CloseListenerSettable.getCloseListener()
Get the close listener.
|
ChannelListener<? super FixedLengthStreamSourceChannel> |
FixedLengthStreamSourceChannel.getCloseListener() |
ChannelListener<? super FixedLengthStreamSinkChannel> |
FixedLengthStreamSinkChannel.getCloseListener() |
ChannelListener<? super SplitStreamSinkChannel> |
SplitStreamSinkChannel.getCloseListener() |
ChannelListener<? super EmptyStreamSourceChannel> |
EmptyStreamSourceChannel.getCloseListener() |
ChannelListener<? super C> |
TranslatingSuspendableChannel.getCloseListener()
Deprecated.
|
ChannelListener<? super C> |
ReadListenerSettable.getReadListener()
Get the read listener.
|
ChannelListener<? super SplitStreamSourceChannel> |
SplitStreamSourceChannel.getReadListener() |
ChannelListener<? super FixedLengthStreamSourceChannel> |
FixedLengthStreamSourceChannel.getReadListener() |
ChannelListener<? super EmptyStreamSourceChannel> |
EmptyStreamSourceChannel.getReadListener() |
ChannelListener<? super C> |
TranslatingSuspendableChannel.getReadListener()
Deprecated.
|
ChannelListener<? super NullStreamSinkChannel> |
NullStreamSinkChannel.getWriteListener() |
ChannelListener<? super C> |
WriteListenerSettable.getWriteListener()
Get the write listener.
|
ChannelListener<? super FixedLengthStreamSinkChannel> |
FixedLengthStreamSinkChannel.getWriteListener() |
ChannelListener<? super SplitStreamSinkChannel> |
SplitStreamSinkChannel.getWriteListener() |
ChannelListener<? super C> |
TranslatingSuspendableChannel.getWriteListener()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
ReadListenerSettable.Setter.set(ChannelListener<? super C> listener) |
void |
AcceptListenerSettable.Setter.set(ChannelListener<? super C> listener) |
void |
CloseListenerSettable.Setter.set(ChannelListener<? super C> listener) |
void |
WriteListenerSettable.Setter.set(ChannelListener<? super C> listener) |
void |
AcceptListenerSettable.setAcceptListener(ChannelListener<? super C> listener)
Set the accept listener.
|
static <T extends AcceptingChannel<?>> |
Channels.setAcceptListener(T channel,
ChannelListener<? super T> listener)
Set the accept listener for a channel (type-safe).
|
void |
CloseListenerSettable.setCloseListener(ChannelListener<? super C> listener)
Set the close listener.
|
void |
TranslatingSuspendableChannel.setCloseListener(ChannelListener<? super C> closeListener)
Deprecated.
|
void |
EmptyStreamSourceChannel.setCloseListener(ChannelListener<? super EmptyStreamSourceChannel> closeListener) |
void |
FixedLengthStreamSinkChannel.setCloseListener(ChannelListener<? super FixedLengthStreamSinkChannel> listener) |
void |
FixedLengthStreamSourceChannel.setCloseListener(ChannelListener<? super FixedLengthStreamSourceChannel> closeListener) |
void |
NullStreamSinkChannel.setCloseListener(ChannelListener<? super NullStreamSinkChannel> closeListener) |
void |
PushBackStreamChannel.setCloseListener(ChannelListener<? super PushBackStreamChannel> closeListener) |
void |
SplitStreamSinkChannel.setCloseListener(ChannelListener<? super SplitStreamSinkChannel> closeListener) |
void |
SplitStreamSourceChannel.setCloseListener(ChannelListener<? super SplitStreamSourceChannel> closeListener) |
static <T extends CloseableChannel> |
Channels.setCloseListener(T channel,
ChannelListener<? super T> listener)
Set the close listener for a channel (type-safe).
|
void |
ReadListenerSettable.setReadListener(ChannelListener<? super C> listener)
Set the read listener.
|
void |
TranslatingSuspendableChannel.setReadListener(ChannelListener<? super C> readListener)
Deprecated.
|
void |
EmptyStreamSourceChannel.setReadListener(ChannelListener<? super EmptyStreamSourceChannel> readListener) |
void |
FixedLengthStreamSourceChannel.setReadListener(ChannelListener<? super FixedLengthStreamSourceChannel> readListener) |
void |
PushBackStreamChannel.setReadListener(ChannelListener<? super PushBackStreamChannel> readListener) |
void |
SplitStreamSourceChannel.setReadListener(ChannelListener<? super SplitStreamSourceChannel> readListener) |
static <T extends SuspendableReadChannel> |
Channels.setReadListener(T channel,
ChannelListener<? super T> listener)
Set the read listener for a channel (type-safe).
|
void |
WriteListenerSettable.setWriteListener(ChannelListener<? super C> listener)
Set the write listener.
|
void |
TranslatingSuspendableChannel.setWriteListener(ChannelListener<? super C> writeListener)
Deprecated.
|
void |
FixedLengthStreamSinkChannel.setWriteListener(ChannelListener<? super FixedLengthStreamSinkChannel> listener) |
void |
NullStreamSinkChannel.setWriteListener(ChannelListener<? super NullStreamSinkChannel> writeListener) |
void |
SplitStreamSinkChannel.setWriteListener(ChannelListener<? super SplitStreamSinkChannel> writeListener) |
static <T extends SuspendableWriteChannel> |
Channels.setWriteListener(T channel,
ChannelListener<? super T> listener)
Set the write listener for a channel (type-safe).
|
Constructor and Description |
---|
FixedLengthStreamSinkChannel(StreamSinkChannel delegate,
long contentLength,
boolean configurable,
boolean propagateClose,
ChannelListener<? super FixedLengthStreamSinkChannel> finishListener,
Object guard)
Construct a new instance.
|
FixedLengthStreamSourceChannel(StreamSourceChannel delegate,
long contentLength,
boolean configurable,
boolean propagateClose,
ChannelListener<? super FixedLengthStreamSourceChannel> finishListener,
Object guard)
Construct a new instance.
|
FixedLengthStreamSourceChannel(StreamSourceChannel delegate,
long contentLength,
boolean configurable,
ChannelListener<? super FixedLengthStreamSourceChannel> finishListener,
Object guard)
Construct a new instance.
|
FixedLengthStreamSourceChannel(StreamSourceChannel delegate,
long contentLength,
ChannelListener<? super FixedLengthStreamSourceChannel> finishListener,
Object guard)
Construct a new instance.
|
Modifier and Type | Method and Description |
---|---|
ChannelListener<? super ConduitReadableMessageChannel> |
ConduitReadableMessageChannel.getCloseListener() |
ChannelListener<? super ConduitStreamSourceChannel> |
ConduitStreamSourceChannel.getCloseListener() |
ChannelListener<? super ConduitStreamSinkChannel> |
ConduitStreamSinkChannel.getCloseListener() |
ChannelListener<? super ConduitWritableMessageChannel> |
ConduitWritableMessageChannel.getCloseListener() |
ChannelListener<? super ConduitReadableMessageChannel> |
ConduitReadableMessageChannel.getReadListener() |
ChannelListener<? super ConduitStreamSourceChannel> |
ConduitStreamSourceChannel.getReadListener() |
ChannelListener<? super ConduitStreamSinkChannel> |
ConduitStreamSinkChannel.getWriteListener() |
ChannelListener<? super ConduitWritableMessageChannel> |
ConduitWritableMessageChannel.getWriteListener() |
Modifier and Type | Method and Description |
---|---|
void |
ConduitReadableMessageChannel.setCloseListener(ChannelListener<? super ConduitReadableMessageChannel> closeListener) |
void |
ConduitStreamSinkChannel.setCloseListener(ChannelListener<? super ConduitStreamSinkChannel> closeListener) |
void |
ConduitStreamSourceChannel.setCloseListener(ChannelListener<? super ConduitStreamSourceChannel> closeListener) |
void |
ConduitWritableMessageChannel.setCloseListener(ChannelListener<? super ConduitWritableMessageChannel> closeListener) |
void |
ConduitReadableMessageChannel.setReadListener(ChannelListener<? super ConduitReadableMessageChannel> readListener) |
void |
ConduitStreamSourceChannel.setReadListener(ChannelListener<? super ConduitStreamSourceChannel> readListener) |
void |
ConduitStreamSinkChannel.setWriteListener(ChannelListener<? super ConduitStreamSinkChannel> writeListener) |
void |
ConduitWritableMessageChannel.setWriteListener(ChannelListener<? super ConduitWritableMessageChannel> writeListener) |
Modifier and Type | Method and Description |
---|---|
static <T extends StreamConnection> |
HttpUpgrade.performUpgrade(T connection,
URI uri,
Map<String,List<String>> headers,
ChannelListener<? super StreamConnection> openListener,
ExtendedHandshakeChecker handshakeChecker)
Performs a HTTP upgrade on an existing connection.
|
static <T extends StreamConnection> |
HttpUpgrade.performUpgrade(T connection,
URI uri,
Map<String,String> headers,
ChannelListener<? super StreamConnection> openListener,
HandshakeChecker handshakeChecker)
Performs a HTTP upgrade on an existing connection.
|
static IoFuture<StreamConnection> |
HttpUpgrade.performUpgrade(XnioWorker worker,
InetSocketAddress bindAddress,
URI uri,
Map<String,List<String>> headers,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap,
ExtendedHandshakeChecker handshakeChecker)
Connects to the target server using HTTP upgrade.
|
static IoFuture<StreamConnection> |
HttpUpgrade.performUpgrade(XnioWorker worker,
InetSocketAddress bindAddress,
URI uri,
Map<String,List<String>> headers,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap,
ExtendedHandshakeChecker handshakeChecker)
Connects to the target server using HTTP upgrade.
|
static IoFuture<StreamConnection> |
HttpUpgrade.performUpgrade(XnioWorker worker,
InetSocketAddress bindAddress,
URI uri,
Map<String,String> headers,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap,
HandshakeChecker handshakeChecker)
Connects to the target server using HTTP upgrade.
|
static IoFuture<StreamConnection> |
HttpUpgrade.performUpgrade(XnioWorker worker,
InetSocketAddress bindAddress,
URI uri,
Map<String,String> headers,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap,
HandshakeChecker handshakeChecker)
Connects to the target server using HTTP upgrade.
|
static IoFuture<SslConnection> |
HttpUpgrade.performUpgrade(XnioWorker worker,
XnioSsl ssl,
InetSocketAddress bindAddress,
URI uri,
Map<String,List<String>> headers,
ChannelListener<? super SslConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap,
ExtendedHandshakeChecker handshakeChecker)
Perform a HTTP upgrade that results in a SSL secured connection.
|
static IoFuture<SslConnection> |
HttpUpgrade.performUpgrade(XnioWorker worker,
XnioSsl ssl,
InetSocketAddress bindAddress,
URI uri,
Map<String,List<String>> headers,
ChannelListener<? super SslConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap,
ExtendedHandshakeChecker handshakeChecker)
Perform a HTTP upgrade that results in a SSL secured connection.
|
static IoFuture<SslConnection> |
HttpUpgrade.performUpgrade(XnioWorker worker,
XnioSsl ssl,
InetSocketAddress bindAddress,
URI uri,
Map<String,String> headers,
ChannelListener<? super SslConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap,
HandshakeChecker handshakeChecker)
Perform a HTTP upgrade that results in a SSL secured connection.
|
static IoFuture<SslConnection> |
HttpUpgrade.performUpgrade(XnioWorker worker,
XnioSsl ssl,
InetSocketAddress bindAddress,
URI uri,
Map<String,String> headers,
ChannelListener<? super SslConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap,
HandshakeChecker handshakeChecker)
Perform a HTTP upgrade that results in a SSL secured connection.
|
Copyright © 2019 JBoss by Red Hat. All rights reserved.