| Modifier and Type | Class and Description |
|---|---|
| private static class |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| public static IoFuture | Returns: An IoFuture of the connectionThe worker worker, XnioSsl The XnioSsl instance ssl, InetSocketAddress The bind address bindAddress, URI The URI to connect to uri, final Map<String, String> Any additional headers to include in the upgrade request. This must include an headers, ChannelListener<? super SslConnection> Upgrade header that specifies the type of upgrade being performedThe open listener that is invoked once the HTTP upgrade is done openListener, ChannelListener<? super BoundChannel> The bind listener that is invoked when the socket is bound bindListener, OptionMap The option map for the connection optionMap, HandshakeChecker A handshake checker that can be supplied to verify that the server returned a valid response to the upgrade request handshakeChecker)Perform a HTTP upgrade that results in a SSL secured connection. |
| public static IoFuture | Returns: An IoFuture of the connectionThe worker worker, XnioSsl The XnioSsl instance ssl, InetSocketAddress The bind address bindAddress, URI The URI to connect to uri, final Map<String, List<String>> Any additional headers to include in the upgrade request. This must include an headers, ChannelListener<? super SslConnection> Upgrade header that specifies the type of upgrade being performedThe open listener that is invoked once the HTTP upgrade is done openListener, ChannelListener<? super BoundChannel> The bind listener that is invoked when the socket is bound bindListener, OptionMap The option map for the connection optionMap, ExtendedHandshakeChecker A handshake checker that can be supplied to verify that the server returned a valid response to the upgrade request handshakeChecker)Perform a HTTP upgrade that results in a SSL secured connection. |
| public static IoFuture | Returns: An IoFuture of the connectionThe worker worker, InetSocketAddress The bind address bindAddress, URI The URI to connect to uri, final Map<String, String> Any additional headers to include in the upgrade request. This must include an headers, ChannelListener<? super StreamConnection> Upgrade header that specifies the type of upgrade being performedThe open listener that is invoked once the HTTP upgrade is done openListener, ChannelListener<? super BoundChannel> The bind listener that is invoked when the socket is bound bindListener, OptionMap The option map for the connection optionMap, HandshakeChecker A handshake checker that can be supplied to verify that the server returned a valid response to the upgrade request handshakeChecker)Connects to the target server using HTTP upgrade. |
| public static IoFuture | Returns: An IoFuture of the connectionThe worker worker, InetSocketAddress The bind address bindAddress, URI The URI to connect to uri, final Map<String, List<String>> Any additional headers to include in the upgrade request. This must include an headers, ChannelListener<? super StreamConnection> Upgrade header that specifies the type of upgrade being performedThe open listener that is invoked once the HTTP upgrade is done openListener, ChannelListener<? super BoundChannel> The bind listener that is invoked when the socket is bound bindListener, OptionMap The option map for the connection optionMap, ExtendedHandshakeChecker A handshake checker that can be supplied to verify that the server returned a valid response to the upgrade request handshakeChecker)Connects to the target server using HTTP upgrade. |
| public static <T extends StreamConnection> IoFuture | Returns: An IoFuture of the connectionThe existing connection to upgrade connection, URI The URI to connect to uri, final Map<String, String> Any additional headers to include in the upgrade request. This must include an headers, ChannelListener<? super StreamConnection> Upgrade header that specifies the type of upgrade being performedThe open listener that is invoked once the HTTP upgrade is done openListener, HandshakeChecker A handshake checker that can be supplied to verify that the server returned a valid response to the upgrade request handshakeChecker)Performs a HTTP upgrade on an existing connection. |
| public static <T extends StreamConnection> IoFuture | Returns: An IoFuture of the connectionThe existing connection to upgrade connection, URI The URI to connect to uri, final Map<String, List<String>> Any additional headers to include in the upgrade request. This must include an headers, ChannelListener<? super StreamConnection> Upgrade header that specifies the type of upgrade being performedThe open listener that is invoked once the HTTP upgrade is done openListener, ExtendedHandshakeChecker A handshake checker that can be supplied to verify that the server returned a valid response to the upgrade request handshakeChecker)Performs a HTTP upgrade on an existing connection. |
| HttpUpgrade | back to summary |
|---|---|
| private HttpUpgrade() | |
| performUpgrade | back to summary |
|---|---|
| public static IoFuture Perform a HTTP upgrade that results in a SSL secured connection. This method should be used if the target endpoint is using https
| |
| performUpgrade | back to summary |
|---|---|
| public static IoFuture Perform a HTTP upgrade that results in a SSL secured connection. This method should be used if the target endpoint is using https
| |
| performUpgrade | back to summary |
|---|---|
| public static IoFuture Connects to the target server using HTTP upgrade.
| |
| performUpgrade | back to summary |
|---|---|
| public static IoFuture Connects to the target server using HTTP upgrade.
| |
| performUpgrade | back to summary |
|---|---|
| public static <T extends StreamConnection> IoFuture Performs a HTTP upgrade on an existing connection.
| |
| performUpgrade | back to summary |
|---|---|
| public static <T extends StreamConnection> IoFuture Performs a HTTP upgrade on an existing connection.
| |
| Modifier and Type | Class and Description |
|---|---|
| private class | |
| private class | |
| private class | |
| private class |
| Modifier and Type | Field and Description |
|---|---|
| private final InetSocketAddress | |
| private final ChannelListener | |
| private T | |
| private final FutureResult | |
| private final Object | |
| private final Map | |
| private final ChannelListener | |
| private final OptionMap | |
| private final XnioSsl | |
| private final URI | |
| private final XnioWorker |
| Access | Constructor and Description |
|---|---|
| private | HttpUpgradeState(final XnioWorker worker, final XnioSsl ssl, final InetSocketAddress bindAddress, final URI uri, final Map<String, String> headers, final ChannelListener<? super T> openListener, final ChannelListener<? super BoundChannel> bindListener, final OptionMap optionMap, final HandshakeChecker handshakeChecker)
|
| private | HttpUpgradeState(final XnioWorker worker, final XnioSsl ssl, final InetSocketAddress bindAddress, final URI uri, final Map<String, List<String>> headers, final ChannelListener<? super T> openListener, final ChannelListener<? super BoundChannel> bindListener, final OptionMap optionMap, final ExtendedHandshakeChecker handshakeChecker)
|
| public | HttpUpgradeState(final T connection, final URI uri, final Map<String, String> headers, final ChannelListener<? super StreamConnection> openListener, final HandshakeChecker handshakeChecker)
|
| public | HttpUpgradeState(final T connection, final URI uri, final Map<String, List<String>> headers, final ChannelListener<? super StreamConnection> openListener, final ExtendedHandshakeChecker handshakeChecker)
|
| Modifier and Type | Method and Description |
|---|---|
| private String | |
| private IoFuture | |
| private void | |
| private String | |
| private void | |
| private void | |
| public IoFuture |
| bindAddress | back to summary |
|---|---|
| private final InetSocketAddress bindAddress | |
| bindListener | back to summary |
|---|---|
| private final ChannelListener<? super BoundChannel> bindListener | |
| connection | back to summary |
|---|---|
| private T connection | |
| future | back to summary |
|---|---|
| private final FutureResult<T> future | |
| handshakeChecker | back to summary |
|---|---|
| private final Object handshakeChecker | |
| headers | back to summary |
|---|---|
| private final Map<String, List<String>> headers | |
| openListener | back to summary |
|---|---|
| private final ChannelListener<? super T> openListener | |
| optionMap | back to summary |
|---|---|
| private final OptionMap optionMap | |
| ssl | back to summary |
|---|---|
| private final XnioSsl ssl | |
| uri | back to summary |
|---|---|
| private final URI uri | |
| worker | back to summary |
|---|---|
| private final XnioWorker worker | |
| HttpUpgradeState | back to summary |
|---|---|
| private HttpUpgradeState(final XnioWorker worker, final XnioSsl ssl, final InetSocketAddress bindAddress, final URI uri, final Map<String, String> headers, final ChannelListener<? super T> openListener, final ChannelListener<? super BoundChannel> bindListener, final OptionMap optionMap, final HandshakeChecker handshakeChecker) | |
| HttpUpgradeState | back to summary |
|---|---|
| private HttpUpgradeState(final XnioWorker worker, final XnioSsl ssl, final InetSocketAddress bindAddress, final URI uri, final Map<String, List<String>> headers, final ChannelListener<? super T> openListener, final ChannelListener<? super BoundChannel> bindListener, final OptionMap optionMap, final ExtendedHandshakeChecker handshakeChecker) | |
| HttpUpgradeState | back to summary |
|---|---|
| public HttpUpgradeState(final T connection, final URI uri, final Map<String, String> headers, final ChannelListener<? super StreamConnection> openListener, final HandshakeChecker handshakeChecker) | |
| HttpUpgradeState | back to summary |
|---|---|
| public HttpUpgradeState(final T connection, final URI uri, final Map<String, List<String>> headers, final ChannelListener<? super StreamConnection> openListener, final ExtendedHandshakeChecker handshakeChecker) | |
| buildHttpRequest | back to summary |
|---|---|
| private String buildHttpRequest() | |
| doUpgrade | back to summary |
|---|---|
| private IoFuture | |
| flushUpgradeChannel | back to summary |
|---|---|
| private void flushUpgradeChannel() | |
| getHost | back to summary |
|---|---|
| private String getHost() | |
| handleRedirect | back to summary |
|---|---|
| private void handleRedirect(final HttpUpgradeParser parser) | |
| handleUpgrade | back to summary |
|---|---|
| private void handleUpgrade(final HttpUpgradeParser parser) | |
| upgradeExistingConnection | back to summary |
|---|---|
| public IoFuture | |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| public void | handleEvent(final StreamConnection
the channel event channel)Implements org. Handle the event on this channel. |
| ConnectionOpenListener | back to summary |
|---|---|
| private ConnectionOpenListener() | |
| handleEvent | back to summary |
|---|---|
| public void handleEvent(final StreamConnection channel) Implements org. Doc from org. Handle the event on this channel.
| |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| public void | handleCancelled(Object
the attachment attachment)Overrides org. Handle cancellation. |
| public void | handleFailed(IOException
the failure reason exception, Object the attachment attachment)Overrides org. Handle failure. |
| FailureNotifier | back to summary |
|---|---|
| private FailureNotifier() | |
| handleCancelled | back to summary |
|---|---|
| public void handleCancelled(Object attachment) Overrides org. Doc from org. Handle cancellation. | |
| handleFailed | back to summary |
|---|---|
| public void handleFailed(IOException exception, Object attachment) Overrides org. Doc from org. Handle failure.
| |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final ByteBuffer |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| public void | handleEvent(final StreamSinkChannel
the channel event channel)Implements org. Handle the event on this channel. |
| buffer | back to summary |
|---|---|
| pack-priv final ByteBuffer buffer | |
| StringWriteListener | back to summary |
|---|---|
| private StringWriteListener(final ByteBuffer buffer) | |
| handleEvent | back to summary |
|---|---|
| public void handleEvent(final StreamSinkChannel channel) Implements org. Doc from org. Handle the event on this channel.
| |
| Modifier and Type | Field and Description |
|---|---|
| private ByteBuffer | |
| private final HttpUpgradeParser |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| public void | handleEvent(final StreamSourceChannel
the channel event channel)Implements org. Handle the event on this channel. |
| buffer | back to summary |
|---|---|
| private ByteBuffer buffer | |
| parser | back to summary |
|---|---|
| private final HttpUpgradeParser parser | |
| UpgradeResultListener | back to summary |
|---|---|
| private UpgradeResultListener() | |
| handleEvent | back to summary |
|---|---|
| public void handleEvent(final StreamSourceChannel channel) Implements org. Doc from org. Handle the event on this channel.
| |