Top Description Inners Fields Constructors Methods
io.undertow.client.http2

public Class Http2ClientProvider

extends Object
implements ClientProvider
Class Inheritance
All Implemented Interfaces
io.undertow.client.ClientProvider
Imports
io.undertow.UndertowLogger, .UndertowMessages, .UndertowOptions, io.undertow.client.ALPNClientSelector, .ClientCallback, .ClientConnection, .ClientProvider, .ClientStatistics, io.undertow.client.http.HttpClientProvider, io.undertow.conduits.ByteActivityCallback, .BytesReceivedStreamSourceConduit, .BytesSentStreamSinkConduit, io.undertow.connector.ByteBufferPool, io.undertow.protocols.http2.Http2Channel, org.xnio.ChannelListener, .IoFuture, .IoUtils, .OptionMap, .Options, .StreamConnection, .XnioIoThread, .XnioWorker, org.xnio.ssl.SslConnection, .XnioSsl, java.net.InetSocketAddress, .URI, java.util.Arrays, .HashSet, .Set
Plaintext HTTP2 client provider that works using HTTP upgrade
Author
Stuart Douglas

Nested and Inner Type Summary

Modifier and TypeClass and Description
private static class
Http2ClientProvider.ClientStatisticsImpl

Field Summary

Modifier and TypeField and Description
private static final ChannelListener<SslConnection>
FAILED

private static final String
HTTP2

private static final String
HTTP_1_1

Constructor Summary

AccessConstructor and Description
public
Http2ClientProvider()

Method Summary

Modifier and TypeMethod and Description
public static ALPNClientSelector.ALPNProtocol
alpnProtocol(final ClientCallback<ClientConnection> listener, URI uri, ByteBufferPool bufferPool, OptionMap options)

public void
connect(final ClientCallback<ClientConnection> listener, final URI uri, final XnioWorker worker, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options)

Implements io.undertow.client.ClientProvider.connect.

public void
connect(final ClientCallback<ClientConnection> listener, final URI uri, final XnioIoThread ioThread, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options)

Implements io.undertow.client.ClientProvider.connect.

public void
connect(final ClientCallback<ClientConnection> listener, InetSocketAddress bindAddress, final URI uri, final XnioWorker worker, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options)

Implements io.undertow.client.ClientProvider.connect.

public void
connect(final ClientCallback<ClientConnection> listener, InetSocketAddress bindAddress, final URI uri, final XnioIoThread ioThread, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options)

Implements io.undertow.client.ClientProvider.connect.

private static Http2ClientConnection
createHttp2Channel(StreamConnection connection, ByteBufferPool bufferPool, OptionMap options, String defaultHost)

private IoFuture.Notifier<StreamConnection, Object>
createNotifier(final ClientCallback<ClientConnection> listener)

private ChannelListener<StreamConnection>
createOpenListener(final ClientCallback<ClientConnection> listener, final URI uri, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options)

private void
handleConnected(StreamConnection connection, final ClientCallback<ClientConnection> listener, URI uri, ByteBufferPool bufferPool, OptionMap options)

public Set<String>
handlesSchemes()

Implements io.undertow.client.ClientProvider.handlesSchemes.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

FAILEDback to summary
private static final ChannelListener<SslConnection> FAILED
HTTP2back to summary
private static final String HTTP2
HTTP_1_1back to summary
private static final String HTTP_1_1

Constructor Detail

Http2ClientProviderback to summary
public Http2ClientProvider()

Method Detail

alpnProtocolback to summary
public static ALPNClientSelector.ALPNProtocol alpnProtocol(final ClientCallback<ClientConnection> listener, URI uri, ByteBufferPool bufferPool, OptionMap options)
connectback to summary
public void connect(final ClientCallback<ClientConnection> listener, final URI uri, final XnioWorker worker, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options)

Implements io.undertow.client.ClientProvider.connect.

Annotations
@Override
connectback to summary
public void connect(final ClientCallback<ClientConnection> listener, final URI uri, final XnioIoThread ioThread, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options)

Implements io.undertow.client.ClientProvider.connect.

Annotations
@Override
connectback to summary
public void connect(final ClientCallback<ClientConnection> listener, InetSocketAddress bindAddress, final URI uri, final XnioWorker worker, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options)

Implements io.undertow.client.ClientProvider.connect.

Annotations
@Override
connectback to summary
public void connect(final ClientCallback<ClientConnection> listener, InetSocketAddress bindAddress, final URI uri, final XnioIoThread ioThread, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options)

Implements io.undertow.client.ClientProvider.connect.

Annotations
@Override
createHttp2Channelback to summary
private static Http2ClientConnection createHttp2Channel(StreamConnection connection, ByteBufferPool bufferPool, OptionMap options, String defaultHost)
createNotifierback to summary
private IoFuture.Notifier<StreamConnection, Object> createNotifier(final ClientCallback<ClientConnection> listener)
createOpenListenerback to summary
private ChannelListener<StreamConnection> createOpenListener(final ClientCallback<ClientConnection> listener, final URI uri, final XnioSsl ssl, final ByteBufferPool bufferPool, final OptionMap options)
handleConnectedback to summary
private void handleConnected(StreamConnection connection, final ClientCallback<ClientConnection> listener, URI uri, ByteBufferPool bufferPool, OptionMap options)
handlesSchemesback to summary
public Set<String> handlesSchemes()

Implements io.undertow.client.ClientProvider.handlesSchemes.

Annotations
@Override
io.undertow.client.http2 back to summary

private Class Http2ClientProvider.ClientStatisticsImpl

extends Object
implements ClientStatistics
Class Inheritance
  • java.lang.Object
  • io.undertow.client.http2.Http2ClientProvider.ClientStatisticsImpl
All Implemented Interfaces
io.undertow.client.ClientStatistics

Field Summary

Modifier and TypeField and Description
private long
read

private long
requestCount

private long
written

Constructor Summary

AccessConstructor and Description
private
ClientStatisticsImpl()

Method Summary

Modifier and TypeMethod and Description
public long
getRead()

Implements io.undertow.client.ClientStatistics.getRead.

public long
getRequests()

Implements io.undertow.client.ClientStatistics.getRequests.

public long
getWritten()

Implements io.undertow.client.ClientStatistics.getWritten.

public void
reset()

Implements io.undertow.client.ClientStatistics.reset.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

readback to summary
private long read
requestCountback to summary
private long requestCount
writtenback to summary
private long written

Constructor Detail

ClientStatisticsImplback to summary
private ClientStatisticsImpl()

Method Detail

getReadback to summary
public long getRead()

Implements io.undertow.client.ClientStatistics.getRead.

Annotations
@Override
getRequestsback to summary
public long getRequests()

Implements io.undertow.client.ClientStatistics.getRequests.

Annotations
@Override
getWrittenback to summary
public long getWritten()

Implements io.undertow.client.ClientStatistics.getWritten.

Annotations
@Override
resetback to summary
public void reset()

Implements io.undertow.client.ClientStatistics.reset.

Annotations
@Override