|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
HttpAsyncRequestConsumer implementation that relieves its
subclasses from having to manage internal state and provides a number of protected
event methods that they need to implement.HttpAsyncResponseConsumer implementation that relieves its
subclasses from having to manage internal state and provides a number of protected
event methods that they need to implement.ContentDecoder that serves as a base for all content
decoder implementations.ContentEncoder that serves as a base for all content
encoder implementations.IOEventDispatch implementation that supports both plain (non-encrypted)
and SSL encrypted HTTP connections.IOReactor that can used as a subclass
for more specialized I/O reactors.NHttpMessageParser that serves as a base for all message
parser implementations.AbstractMessageParser.AbstractMessageParser(SessionInputBuffer, LineParser,
MessageConstraints)
NHttpMessageWriter that serves as a base for all message
writer implementations.AbstractMessageWriter.AbstractMessageWriter(SessionOutputBuffer, LineFormatter)
IOReactor that can run multiple
BaseIOReactor instance in separate worker threads and distribute
newly created I/O session equally across those I/O reactors for a more
optimal resource utilization and a better I/O performance.AbstractMultiworkerIOReactor.AbstractMultiworkerIOReactor(IOReactorConfig, ThreadFactory)
AbstractNIOConnPool.AbstractNIOConnPool(ConnectingIOReactor,
NIOConnFactory, SocketAddressResolver, int, int)
SelectionKey.OP_ACCEPT readiness.
SelectionKey.OP_ACCEPT event.
Throwable object with the given time stamp
to the audit log.
Throwable object to the audit log.
ByteBuffer of the given size.
HttpAsyncRequestExecutor and HttpAsyncRequesterHttpAsyncServiceAbstractIOReactor that serves as a base
for more advanced IOReactor
implementations.HttpAsyncClientExchangeHandler that executes
a single HTTP request / response exchange.HttpAsyncRequestConsumer.BasicAsyncClientExchangeHandler.HttpAsyncRequestHandler that delegates
the process of request handling to a HttpRequestHandler.HttpAsyncRequestProducer.HttpAsyncResponseConsumer.HttpAsyncResponseProducer.NIOConnFactory implementation that creates
NHttpClientConnection instances given a HttpHost instance.BasicNIOConnFactory.BasicNIOConnFactory(SSLContext,
SSLSetupHandler, NHttpMessageParserFactory, NHttpMessageWriterFactory,
ByteBufferAllocator, ConnectionConfig)
BasicNIOConnFactory.BasicNIOConnFactory(SSLContext,
SSLSetupHandler, ConnectionConfig)
BasicNIOConnFactory.BasicNIOConnFactory(ConnectionConfig)
ConnPool implementation that
represents a pool of non-blocking NHttpClientConnection connections
identified by an HttpHost instance.BasicNIOConnPool.BasicNIOConnPool(ConnectingIOReactor, NIOConnFactory, int)
BasicNIOConnPool.BasicNIOConnPool(ConnectingIOReactor,
ConnectionConfig)
PoolEntry implementation that represents an entry
in a pool of non-blocking NHttpClientConnections identified by
an HttpHost instance.IOSession.
BufferInfoHttpAsyncRequestExecutor and HttpAsyncRequesterHttpAsyncServiceBasicAsyncRequestProducer
or BasicAsyncResponseProducerByteBuffer instances.SessionRequest.
SocketChannel entry maintained by the I/O reactor.SessionRequest.
SelectionKey.OP_CONNECT readiness.
SelectionKey.OP_CONNECT event.
SSLBuffer of size.
AbstractAsyncRequestConsumer.onContentReceived(ContentDecoder, IOControl) instead.
AbstractAsyncResponseConsumer.onContentReceived(ContentDecoder, IOControl) instead.
ContentDecoder.
ContentDecoder.
ContentDecoder.
SharedInputBuffer.consumeContent(ContentDecoder, IOControl)
BasicAsyncRequestProducer
or BasicAsyncResponseProducerBasicAsyncRequestProducer
or BasicAsyncResponseProducerContentInputBuffer.ReadableByteChannel that delegates to a ContentDecoder.WritableByteChannel that delegates to a ContentEncoder.InputStream adaptor for ContentInputBuffer.OutputStream adaptor for ContentOutputBuffer.HeapByteBufferAllocator to be used
by HTTP connections for allocating ByteBuffer objects.
HeapByteBufferAllocator to be used
by HTTP connections for allocating ByteBuffer objects.
HeapByteBufferAllocator to be used
by HTTP connections for allocating ByteBuffer objects.
HeapByteBufferAllocator to be used
by HTTP connections for allocating ByteBuffer objects.
DefaultNHttpClientConnection based on the
given IOSession.
DefaultNHttpServerConnection based on the
given IOSession.
DefaultNHttpClientConnection based on the
given SSL IOSession.
DefaultNHttpServerConnection based on the
given IOSession.
ContentDecoder instances.
ContentEncoder instances.
DefaultHttpRequestFactory to be used
by HTTP connections for creating HttpRequest
objects.
DefaultHttpRequestFactory to be used
by HTTP connections for creating HttpRequest
objects.
DefaultHttpResponseFactory to be used
by HTTP connections for creating HttpResponse
objects.
DefaultHttpResponseFactory to be used
by HTTP connections for creating HttpResponse
objects.
HttpMessage instance based on the content of the input
buffer containing the first line of the incoming HTTP message.
SSLIOSession decorating the given
IOSession.
SSLIOSession decorating the given
IOSession.
SSLIOSession decorating the given
IOSession.
SSLIOSession decorating the given
IOSession.
DefaultHttpClientIODispatchConnectingIOReactor.DefaultConnectingIOReactor.DefaultConnectingIOReactor(IOReactorConfig, ThreadFactory)
DefaultConnectingIOReactor.DefaultConnectingIOReactor(IOReactorConfig)
IOEventDispatch implementation
that supports both plain (non-encrypted) and SSL encrypted client side HTTP
connections.DefaultHttpClientIODispatch.DefaultHttpClientIODispatch(
NHttpClientEventHandler, ConnectionConfig)
DefaultHttpClientIODispatch.DefaultHttpClientIODispatch(
NHttpClientEventHandler, SSLContext, SSLSetupHandler, ConnectionConfig)
DefaultHttpClientIODispatch.DefaultHttpClientIODispatch(
NHttpClientEventHandler, SSLContext, ConnectionConfig)
NHttpMessageParser implementation
for HttpRequests.DefaultHttpRequestParser.DefaultHttpRequestParser(
SessionInputBuffer, LineParser, HttpRequestFactory, MessageConstraints)
NHttpMessageWriter implementation
for HttpRequests.DefaultHttpRequestWriter.DefaultHttpRequestWriter(SessionOutputBuffer, LineFormatter)
NHttpMessageParser implementation
for HttpResponses.DefaultHttpResponseParser.DefaultHttpResponseParser(
SessionInputBuffer, LineParser, HttpResponseFactory, MessageConstraints)
NHttpMessageWriter implementation
for HttpResponses.DefaultHttpResponseWriter.DefaultHttpResponseWriter(SessionOutputBuffer, LineFormatter)
IOEventDispatch implementation
that supports both plain (non-encrypted) and SSL encrypted server side HTTP
connections.DefaultHttpServerIODispatch.DefaultHttpServerIODispatch(
NHttpServerEventHandler, ConnectionConfig)
DefaultHttpServerIODispatch.DefaultHttpServerIODispatch(
NHttpServerEventHandler, SSLContext, SSLSetupHandler, ConnectionConfig)
DefaultHttpServerIODispatch.DefaultHttpServerIODispatch(
NHttpServerEventHandler, SSLContext, ConnectionConfig)
ListeningIOReactor.DefaultListeningIOReactor.DefaultListeningIOReactor(IOReactorConfig, ThreadFactory)
DefaultListeningIOReactor.DefaultListeningIOReactor(IOReactorConfig)
NHttpClientConnection
interface.DefaultNHttpClientConnection.DefaultNHttpClientConnection(
IOSession, int, int, ByteBufferAllocator, CharsetDecoder, CharsetEncoder,
MessageConstraints, ContentLengthStrategy, ContentLengthStrategy,
NHttpMessageWriterFactory, NHttpMessageParserFactory)
NHttpClientConnections.DefaultNHttpClientConnectionFactory.DefaultNHttpClientConnectionFactory(
NHttpMessageParserFactory, NHttpMessageWriterFactory, ByteBufferAllocator,
ConnectionConfig)
DefaultNHttpClientConnectionFactory.DefaultNHttpClientConnectionFactory(
ConnectionConfig)
NHttpServerConnection
interface.DefaultNHttpServerConnection.DefaultNHttpServerConnection(
IOSession, int, int, ByteBufferAllocator, CharsetDecoder, CharsetEncoder,
MessageConstraints, ContentLengthStrategy, ContentLengthStrategy,
NHttpMessageParserFactory, NHttpMessageWriterFactory)
NHttpServerConnections.DefaultNHttpServerConnectionFactory.DefaultNHttpServerConnectionFactory(
ByteBufferAllocator, NHttpMessageParserFactory, NHttpMessageWriterFactory,
ConnectionConfig)
DefaultNHttpServerConnectionFactory.DefaultNHttpServerConnectionFactory(ConnectionConfig)
DefaultHttpServerIODispatchByteBuffer instances using
ByteBuffer.allocateDirect(int).HttpAsyncContentProducer that relies on
inefficient and potentially blocking I/O operation redirection through
Channels.newChannel(java.io.InputStream).Throwable instance along with a time stamp.IOEventDispatch.
ByteBufferAllocator
interface.SessionRequest.
FileChannelFileChannelReadableByteChannel.
ReadableByteChannel.
NByteArrayEntity.close()
NFileEntity.close()
NStringEntity.close()
WritableByteChannel.
ConnectionReuseStrategy implementation to be used
to determine whether or not the underlying connection can be kept alive
after a particular HTTP request / response exchange.
InputStream.
UnsupportedOperationException.
NIOReactorPNames.CONTENT_BUFFER_SIZE parameter.
HttpContext instance.
ioThreadCount.
IOException thrown during initialization
of this endpoint or null, if initialization was successful.
IOException instance if the request could not be
successfully executed due to an I/O error or null if no
error occurred to this point.
NIOReactorPNames.GRACE_PERIOD parameter.
HttpProcessor implementation to be used to process
HTTP request and response messages for protocol compliance.
true if interest Ops queueing is enabled, false otherwise.
NIOReactorPNames.INTEREST_OPS_QUEUEING parameter.
SocketOptions.SO_RCVBUF parameter
for newly created sockets.
HttpRequest
NIOReactorPNames.SELECT_INTERVAL parameter.
IOSession instance associated with the given selection
key.
IOSession instance created as a result of this request
or null if the request is still pending.
SocketOptions.SO_SNDBUF parameter
for newly created sockets.
SocketOptions.SO_LINGER parameter
for newly created sockets.
RuntimeException.
0.
ByteBuffer instances using
ByteBuffer.allocate(int).HttpAsyncClientExchangeHandler represents a callback interface whose
methods get invoked when executing one or multiple HTTP message exchanges
on the client side.HttpAsyncContentProducer is a callback interface whose methods
get invoked to stream out message content to a non-blocking HTTP connection.HttpAsyncExchange represents a server-side HTTP message exchange
where an HTTP response can be deferred without blocking the I/O event thread
and triggered asynchronously at a later point of later time.HttpAsyncExpectationVerifier defines a strategy to verify whether
or not an incoming HTTP request meets the target server's expectations.HttpAsyncRequestConsumer is a callback interface whose methods
get invoked to process an HTTP request message and to stream message
content from a non-blocking HTTP connection on the server side.HttpAsyncRequester is a utility class that can be used
in conjunction with HttpAsyncRequestExecutor to initiate execution
of asynchronous HTTP requests.HttpAsyncRequester.HttpAsyncRequester(HttpProcessor,
ConnectionReuseStrategy)
HttpAsyncRequester.
HttpAsyncClientExchangeHandlerHttpAsyncRequestExecutor is a fully asynchronous HTTP client side
protocol handler based on the NIO (non-blocking) I/O model.HttpAsyncRequestExecutor.
HttpAsyncRequestHandler represents a routine for asynchronous
processing of a specific group of non-blocking HTTP requests.HttpAsyncRequestHandlerMapper can be used to resolve an instance
of HttpAsyncRequestHandler matching a particular HttpRequest.UriHttpAsyncRequestHandlerMapperHttpAsyncRequestHandlerMapperHttpAsyncRequestProducer is a callback interface whose methods
get invoked to generate an HTTP request message and to stream message
content to a non-blocking HTTP connection.HttpAsyncResponseConsumer is a callback interface whose methods
get invoked to process an HTTP response message and to stream message
content from a non-blocking HTTP connection on the client side.HttpAsyncResponseProducer is a callback interface whose methods
get invoked to generate an HTTP response message and to stream message
content to a non-blocking HTTP connection on the server side.HttpAsyncService is a fully asynchronous HTTP server side protocol
handler based on the non-blocking (NIO) I/O model.HttpAsyncService.HttpAsyncService(HttpProcessor,
ConnectionReuseStrategy, HttpResponseFactory, HttpAsyncRequestHandlerMapper,
HttpAsyncExpectationVerifier)
HttpAsyncService.HttpAsyncService(HttpProcessor,
ConnectionReuseStrategy, HttpResponseFactory, HttpAsyncRequestHandlerMapper,
HttpAsyncExpectationVerifier)
HttpAsyncServerProtocolHandler.
HttpAsyncServerProtocolHandler.
HttpAsyncServerProtocolHandler.
HttpAsyncServerProtocolHandler.
HttpAsyncRequestExecutor and HttpAsyncRequesterDefaultHttpRequestParserDefaultHttpRequestWriterDefaultHttpResponseParserDefaultHttpResponseWriterIOSession.true if the entity has been received in its
entirety.
true if the entity has been transferred in its
entirety.
true is the session has been fully initialized,
false otherwise.
SelectionKey immediately.
true if an HTTP request has been submitted to the
target server.
true if an HTTP response has been submitted to the
client.
SocketOptions.SO_KEEPALIVE parameter
for newly created sockets.
SocketOptions.SO_REUSEADDR parameter
for newly created sockets.
SocketOptions.TCP_NODELAY parameter
for newly created sockets.
ListenerEndpoint.Closeable objects (such as
HttpConnection}).
Closeable objects (such as
HttpConnection}).
Closeable objects (such as
HttpConnection).
File
with the given content type.
File
with the given content type.
NFileEntity.NFileEntity(File, ContentType, boolean)
NFileEntity.NFileEntity(File, ContentType)
NHttpClientEventHandlerNHttpConnection implementations and provides
functionality common to both client and server HTTP connections.NHttpConnectionBase.NHttpConnectionBase(IOSession, int, int, ByteBufferAllocator,
CharsetDecoder, CharsetEncoder, ContentLengthStrategy, ContentLengthStrategy)
NHttpConnection instances.EntityAsyncContentProducerNHttpMessageParser instances.NHttpMessageWriter instances.HttpAsyncRequestExecutor and HttpAsyncRequesterHttpAsyncRequestHandlerUriHttpAsyncRequestHandlerMapperHttpAsyncRequestHandlerResolverHttpAsyncExchangeNHttpServerEventHandlerIOReactorConfigIOReactorConfigIOReactorConfigString object.ContentDecoder.
ContentDecoder.
SSLBufferManagementStrategy that never releases the underlying buffer.HttpAsyncClientExchangeHandler
that executes a series of pipelined HTTP requests.PipeliningClientExchangeHandler.
PipeliningClientExchangeHandler.
ContentDecoder implementation based on the
properties of the given HttpMessage and generates an instance of
HttpEntity matching the properties of the content decoder.
ContentEncoder implementation based on the
properties of the given HttpMessage.
Socket by resetting some of its properties.
Selector.
ContentEncoder.
ContentEncoder.
ContentEncoder.
ContentEncoder.
SharedOutputBuffer.produceContent(ContentEncoder, IOControl)
BasicAsyncRequestProducer
or BasicAsyncResponseProducerlen bytes of data from this buffer into
an array of bytes.
SelectionKey.OP_READ readiness.
SelectionKey.OP_READ event on the given selection key.
HttpAsyncRequestHandler as a handler for URIs
matching the given pattern.
NHttpRequestHandler as a handler for URIs
matching the given pattern.
HttpAsyncRequestHandler as a handler for URIs
matching the given pattern.
Selector.
HttpAsyncRequestHandler
as a handler for URIs matching the given pattern.
SSLBufferManagementStrategy that releases the underlying buffer when deactivated.AbstractAsyncRequestConsumer.buildResult(HttpContext) instead.
AbstractAsyncRequestConsumer.onRequestReceived(HttpRequest) instead.
SocketAddressResolver
SocketAddressResolver
SocketAddressResolver
SocketAddressResolver
AbstractAsyncResponseConsumer.buildResult(HttpContext) instead.
AbstractAsyncResponseConsumer.onResponseReceived(HttpResponse) instead.
IOSessionImplSessionInputBuffer based on
the ExpandableBuffer class.SessionInputBufferImpl.SessionInputBufferImpl(int, int, CharsetDecoder,
ByteBufferAllocator)
SessionInputBufferImpl.SessionInputBufferImpl(int, int, Charset)
SessionOutputBuffer based on
the ExpandableBuffer class.SessionOutputBufferImpl.SessionOutputBufferImpl(int, int, CharsetEncoder,
ByteBufferAllocator)
SessionOutputBufferImpl.SessionOutputBufferImpl(int, int, Charset)
SessionRequest along
with the time the request was made.SessionRequest.Cancellable callback to be invoked in case the underlying
connection times out or gets terminated prematurely by the client.
NHttpConnectionFactory instance.
ConnectionReuseStrategy instance.
IOReactorConfig.Builder.setConnectTimeout(int)
NIOReactorPNames.CONTENT_BUFFER_SIZE parameter.
ioThreadCount.
ExceptionLogger instance.
HttpAsyncExpectationVerifier instance.
NIOReactorPNames.GRACE_PERIOD parameter.
HttpAsyncRequestHandlerMapper instance.
HttpProcessor instance.
IOReactorConfig.Builder.setInterestOpQueued(boolean)
NIOReactorPNames.INTEREST_OPS_QUEUEING parameter.
IOReactorConfig.Builder.setIoThreadCount(int)
IOReactorConfig.Builder.setRcvBufSize(int)
HttpResponseFactory instance.
IOReactorConfig.Builder.setSelectInterval(long)
NIOReactorPNames.SELECT_INTERVAL parameter.
Server response header value.
IOReactorConfig.Builder.setShutdownGracePeriod(long)
IOReactorConfig.Builder.setSndBufSize(int)
IOReactorConfig.Builder.setSoKeepAlive(boolean)
IOReactorConfig.Builder.setSoLinger(int)
IOReactorConfig.Builder.setSoReuseAddress(boolean)
IOReactorConfig.Builder.setSoTimeout(int)
SSLContext instance.
SSLSetupHandler instance.
IOReactorConfig.Builder.setTcpNoDelay(boolean)
ContentInputBuffer interface that can be
shared by multiple threads, usually the I/O dispatch of an I/O reactor and
a worker thread.SharedInputBuffer.SharedInputBuffer(int, ByteBufferAllocator)
ContentOutputBuffer interface that can be
shared by multiple threads, usually the I/O dispatch of an I/O reactor and
a worker thread.SharedOutputBuffer.SharedOutputBuffer(int, ByteBufferAllocator)
ContentInputBuffer interface.BasicAsyncRequestHandlerContentOutputBuffer interface.SocketAddress.DefaultHttpClientIODispatchSSLContext.
SSLContext.
SSLClientIOEventDispatchSSLContext.
SSLContext.
SSLIOSessionSSLIOSession is a decorator class intended to transparently extend
an IOSession with transport layer security capabilities based on
the SSL/TLS protocol.SSLIOSession class.
SSLIOSession class.
SSLIOSession class.
SSLSetupHandlerNHttpClientConnections.SSLNHttpClientConnectionFactory.SSLNHttpClientConnectionFactory(SSLContext,
SSLSetupHandler, NHttpMessageParserFactory, NHttpMessageWriterFactory,
ByteBufferAllocator, ConnectionConfig)
SSLNHttpClientConnectionFactory.SSLNHttpClientConnectionFactory(SSLContext,
SSLSetupHandler, ConnectionConfig)
SSLNHttpClientConnectionFactory.SSLNHttpClientConnectionFactory(ConnectionConfig)
NHttpServerConnections.SSLNHttpServerConnectionFactory.SSLNHttpServerConnectionFactory(SSLContext,
SSLSetupHandler, NHttpMessageParserFactory, NHttpMessageWriterFactory,
ByteBufferAllocator, ConnectionConfig)
SSLNHttpServerConnectionFactory.SSLNHttpServerConnectionFactory(SSLContext,
SSLSetupHandler, ConnectionConfig)
SSLNHttpServerConnectionFactory.SSLNHttpServerConnectionFactory(ConnectionConfig)
DefaultHttpServerIODispatchSSLContext.
SSLContext.
SSLServerIOEventDispatchSSLContext.
SSLContext.
SSLSetupHandlerHttpRequest to be sent to the target server.
HttpAsyncResponseProducer.
HttpAsyncRequestExecutor and HttpAsyncRequesterHttpAsyncServiceSessionRequest times out.
AbstractIOReactor.timeoutCheck(SelectionKey, long)
method.
SelectionKey.OP_WRITE readiness.
SelectionKey.OP_WRITE event on the given selection key.
len bytes from the specified byte array
starting at offset off to this buffer.
HttpMessage.
UnsupportedOperationException.
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||