Package | Description |
---|---|
io.undertow | |
io.undertow.client | |
io.undertow.client.http2 | |
io.undertow.conduits | |
io.undertow.protocols.ajp | |
io.undertow.protocols.http2 | |
io.undertow.protocols.ssl | |
io.undertow.server | |
io.undertow.server.handlers | |
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.servlet.core | |
io.undertow.servlet.spec | |
io.undertow.util | |
io.undertow.websockets.client | |
io.undertow.websockets.core | |
io.undertow.websockets.core.protocol | |
io.undertow.websockets.core.protocol.version07 | |
io.undertow.websockets.core.protocol.version08 | |
io.undertow.websockets.core.protocol.version13 | |
org.jboss.remoting3.spi |
Service provider classes and interfaces.
|
org.xnio |
The main API package for XNIO.
|
org.xnio.http | |
org.xnio.ssl |
Utility classes for using and implementing SSL within XNIO providers.
|
Constructor and Description |
---|
ListenerInfo(String protcol,
SocketAddress address,
OpenListener openListener,
UndertowXnioSsl ssl,
AcceptingChannel<? extends StreamConnection> channel) |
Modifier and Type | Method and Description |
---|---|
StreamConnection |
ClientConnection.performUpgrade()
Upgrade the connection, if the underlying protocol supports it.
|
Modifier and Type | Method and Description |
---|---|
StreamConnection |
Http2ClientConnection.performUpgrade() |
Constructor and Description |
---|
IdleTimeoutConduit(StreamConnection connection) |
ReadTimeoutStreamSourceConduit(StreamSourceConduit delegate,
StreamConnection connection,
OpenListener openListener) |
WriteTimeoutStreamSinkConduit(StreamSinkConduit delegate,
StreamConnection connection,
OpenListener openListener) |
Constructor and Description |
---|
AjpClientChannel(StreamConnection connectedStreamChannel,
ByteBufferPool bufferPool,
OptionMap settings)
Create a new
AbstractFramedChannel
8 |
Constructor and Description |
---|
Http2Channel(StreamConnection connectedStreamChannel,
String protocol,
ByteBufferPool bufferPool,
PooledByteBuffer data,
boolean clientSide,
boolean fromUpgrade,
boolean prefaceRequired,
ByteBuffer initialOtherSideSettings,
OptionMap settings) |
Http2Channel(StreamConnection connectedStreamChannel,
String protocol,
ByteBufferPool bufferPool,
PooledByteBuffer data,
boolean clientSide,
boolean fromUpgrade,
boolean prefaceRequired,
OptionMap settings) |
Http2Channel(StreamConnection connectedStreamChannel,
String protocol,
ByteBufferPool bufferPool,
PooledByteBuffer data,
boolean clientSide,
boolean fromUpgrade,
OptionMap settings) |
Modifier and Type | Method and Description |
---|---|
SslConnection |
UndertowXnioSsl.wrapExistingConnection(StreamConnection connection,
OptionMap optionMap) |
SslConnection |
UndertowXnioSsl.wrapExistingConnection(StreamConnection connection,
OptionMap optionMap,
boolean clientMode) |
SslConnection |
UndertowXnioSsl.wrapExistingConnection(StreamConnection connection,
OptionMap optionMap,
URI destinationURI) |
Modifier and Type | Field and Description |
---|---|
protected StreamConnection |
AbstractServerConnection.channel |
Modifier and Type | Method and Description |
---|---|
StreamConnection |
AbstractServerConnection.getChannel()
Get the underlying channel.
|
protected abstract StreamConnection |
ServerConnection.upgradeChannel()
Upgrade the connection, if allowed
|
Modifier and Type | Method and Description |
---|---|
void |
DelegateOpenListener.handleEvent(StreamConnection channel,
PooledByteBuffer additionalData) |
void |
HttpUpgradeListener.handleUpgrade(StreamConnection streamConnection,
HttpServerExchange exchange)
Method that is called once the upgrade is complete.
|
Constructor and Description |
---|
AbstractServerConnection(StreamConnection channel,
ByteBufferPool bufferPool,
HttpHandler rootHandler,
OptionMap undertowOptions,
int bufferSize) |
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 |
---|---|
protected StreamConnection |
AjpServerConnection.upgradeChannel() |
Modifier and Type | Method and Description |
---|---|
void |
AjpOpenListener.handleEvent(StreamConnection channel) |
Constructor and Description |
---|
AjpServerConnection(StreamConnection channel,
ByteBufferPool bufferPool,
HttpHandler rootHandler,
OptionMap undertowOptions,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
protected StreamConnection |
AbstractFramedChannel.getUnderlyingConnection() |
Modifier and Type | Method and Description |
---|---|
protected IdleTimeoutConduit |
AbstractFramedChannel.createIdleTimeoutChannel(StreamConnection connectedStreamChannel) |
Constructor and Description |
---|
AbstractFramedChannel(StreamConnection connectedStreamChannel,
ByteBufferPool bufferPool,
FramePriority<C,R,S> framePriority,
PooledByteBuffer readData,
OptionMap settings)
Create a new
AbstractFramedChannel
8 |
Modifier and Type | Method and Description |
---|---|
protected StreamConnection |
HttpServerConnection.upgradeChannel() |
Modifier and Type | Method and Description |
---|---|
void |
AlpnOpenListener.handleEvent(StreamConnection channel) |
void |
HttpOpenListener.handleEvent(StreamConnection channel) |
void |
HttpOpenListener.handleEvent(StreamConnection channel,
PooledByteBuffer buffer) |
Constructor and Description |
---|
HttpServerConnection(StreamConnection channel,
ByteBufferPool bufferPool,
HttpHandler rootHandler,
OptionMap undertowOptions,
int bufferSize,
ConnectorStatisticsImpl connectorStatistics) |
Modifier and Type | Method and Description |
---|---|
protected StreamConnection |
Http2ServerConnection.upgradeChannel() |
Modifier and Type | Method and Description |
---|---|
void |
Http2OpenListener.handleEvent(StreamConnection channel) |
void |
Http2OpenListener.handleEvent(StreamConnection channel,
PooledByteBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
void |
ProxyProtocolOpenListener.handleEvent(StreamConnection streamConnection) |
Modifier and Type | Method and Description |
---|---|
void |
ServletUpgradeListener.handleUpgrade(StreamConnection channel,
HttpServerExchange exchange) |
Constructor and Description |
---|
WebConnectionImpl(StreamConnection channel,
ByteBufferPool bufferPool,
Executor ioExecutor) |
Modifier and Type | Method and Description |
---|---|
static void |
ConnectionUtils.cleanClose(StreamConnection connection,
Closeable... additional)
Cleanly close a connection, by shutting down and flushing writes and then draining reads.
|
Modifier and Type | Method and Description |
---|---|
WebSocketChannel |
WebSocket13ClientHandshake.createChannel(StreamConnection channel,
String wsUri,
ByteBufferPool bufferPool,
OptionMap options) |
abstract WebSocketChannel |
WebSocketClientHandshake.createChannel(StreamConnection channel,
String wsUri,
ByteBufferPool bufferPool,
OptionMap options) |
Modifier and Type | Method and Description |
---|---|
protected IdleTimeoutConduit |
WebSocketChannel.createIdleTimeoutChannel(StreamConnection connectedStreamChannel) |
Constructor and Description |
---|
WebSocketChannel(StreamConnection connectedStreamChannel,
ByteBufferPool bufferPool,
WebSocketVersion version,
String wsUrl,
String subProtocol,
boolean client,
boolean extensionsSupported,
ExtensionFunction extensionFunction,
Set<WebSocketChannel> peerConnections,
OptionMap options)
Create a new
WebSocketChannel
8 |
Modifier and Type | Method and Description |
---|---|
abstract WebSocketChannel |
Handshake.createChannel(WebSocketHttpExchange exchange,
StreamConnection channel,
ByteBufferPool pool)
Create the
WebSocketChannel from the WebSocketHttpExchange |
Modifier and Type | Method and Description |
---|---|
WebSocketChannel |
Hybi07Handshake.createChannel(WebSocketHttpExchange exchange,
StreamConnection channel,
ByteBufferPool pool) |
Constructor and Description |
---|
WebSocket07Channel(StreamConnection channel,
ByteBufferPool bufferPool,
String wsUrl,
String subProtocol,
boolean client,
boolean allowExtensions,
ExtensionFunction extensionFunction,
Set<WebSocketChannel> openConnections,
OptionMap options)
Create a new
WebSocket07Channel |
Modifier and Type | Method and Description |
---|---|
WebSocketChannel |
Hybi08Handshake.createChannel(WebSocketHttpExchange exchange,
StreamConnection channel,
ByteBufferPool pool) |
Constructor and Description |
---|
WebSocket08Channel(StreamConnection channel,
ByteBufferPool bufferPool,
String wsUrl,
String subProtocols,
boolean client,
boolean allowExtensions,
ExtensionFunction extensionFunction,
Set<WebSocketChannel> openConnections,
OptionMap options) |
Modifier and Type | Method and Description |
---|---|
WebSocketChannel |
Hybi13Handshake.createChannel(WebSocketHttpExchange exchange,
StreamConnection channel,
ByteBufferPool pool) |
Constructor and Description |
---|
WebSocket13Channel(StreamConnection channel,
ByteBufferPool bufferPool,
String wsUrl,
String subProtocols,
boolean client,
boolean allowExtensions,
ExtensionFunction extensionFunction,
Set<WebSocketChannel> openConnections,
OptionMap options) |
Modifier and Type | Method and Description |
---|---|
Consumer<StreamConnection> |
ExternalConnectionProvider.createConnectionAdaptor(OptionMap optionMap,
SaslAuthenticationFactory saslAuthenticationFactory)
Create a network server.
|
AcceptingChannel<StreamConnection> |
NetworkServerProvider.createServer(SocketAddress bindAddress,
OptionMap optionMap,
SaslAuthenticationFactory saslAuthenticationFactory,
SSLContext sslContext)
Create a network server.
|
Modifier and Type | Method and Description |
---|---|
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<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> |
XnioIoThread.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) |
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 AcceptingChannel<StreamConnection> |
XnioWorker.createLocalStreamConnectionServer(LocalSocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<StreamConnection>> acceptListener,
OptionMap optionMap)
Implementation helper method to create a UNIX domain stream server.
|
AcceptingChannel<StreamConnection> |
XnioWorker.createStreamConnectionServer(SocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<StreamConnection>> acceptListener,
OptionMap optionMap)
Create a stream server, for TCP or UNIX domain servers.
|
protected AcceptingChannel<StreamConnection> |
XnioWorker.createTcpConnectionServer(InetSocketAddress bindAddress,
ChannelListener<? super AcceptingChannel<StreamConnection>> acceptListener,
OptionMap optionMap)
Implementation helper method to create a TCP stream 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<StreamConnection> |
XnioIoFactory.openStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap)
Connect to a remote stream server.
|
IoFuture<StreamConnection> |
XnioIoThread.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> |
XnioIoFactory.openStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
OptionMap optionMap)
Connect to a remote stream server.
|
IoFuture<StreamConnection> |
XnioIoThread.openStreamConnection(SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
OptionMap optionMap) |
IoFuture<StreamConnection> |
XnioWorker.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> |
XnioIoThread.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) |
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.
|
void |
StreamConnection.setCloseListener(ChannelListener<? super StreamConnection> listener) |
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.
|
Modifier and Type | Method and Description |
---|---|
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.
|
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,String> headers,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap,
HandshakeChecker handshakeChecker)
Connects to the target server using HTTP upgrade.
|
Modifier and Type | Class and Description |
---|---|
class |
JsseSslConnection |
class |
JsseSslStreamConnection
StreamConnection with SSL support.
|
class |
SslConnection
A stream connection which can use SSL/TLS to negotiate a security layer.
|
Constructor and Description |
---|
JsseSslConnection(StreamConnection streamConnection,
SSLEngine engine) |
JsseSslStreamConnection(StreamConnection connection,
SSLEngine sslEngine,
boolean startTls) |
Copyright © 2019 JBoss by Red Hat. All rights reserved.