Package org.apache.http.impl.nio.client

Class InternalHttpAsyncClient

java.lang.Object

org.apache.http.impl.nio.client.CloseableHttpAsyncClient

org.apache.http.impl.nio.client.CloseableHttpPipeliningClient

org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase

org.apache.http.impl.nio.client.InternalHttpAsyncClient

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, HttpAsyncClient, HttpPipeliningClient

class InternalHttpAsyncClient
extends CloseableHttpAsyncClientBase

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase

CloseableHttpAsyncClientBase.Status

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.http.config.Lookup<org.apache.http.auth.AuthSchemeProvider>	authSchemeRegistry
private NHttpClientConnectionManager	connmgr
private org.apache.http.ConnectionReuseStrategy	connReuseStrategy
private org.apache.http.config.Lookup<org.apache.http.cookie.CookieSpecProvider>	cookieSpecRegistry
private org.apache.http.client.CookieStore	cookieStore
private org.apache.http.client.CredentialsProvider	credentialsProvider
private org.apache.http.client.config.RequestConfig	defaultConfig
private InternalClientExec	exec
private org.apache.http.conn.ConnectionKeepAliveStrategy	keepaliveStrategy
private org.apache.commons.logging.Log	log

Constructor Summary

Constructors

Constructor

Description

InternalHttpAsyncClient(NHttpClientConnectionManager connmgr, org.apache.http.ConnectionReuseStrategy connReuseStrategy, org.apache.http.conn.ConnectionKeepAliveStrategy keepaliveStrategy, java.util.concurrent.ThreadFactory threadFactory, org.apache.http.nio.NHttpClientEventHandler handler, InternalClientExec exec, org.apache.http.config.Lookup<org.apache.http.cookie.CookieSpecProvider> cookieSpecRegistry, org.apache.http.config.Lookup<org.apache.http.auth.AuthSchemeProvider> authSchemeRegistry, org.apache.http.client.CookieStore cookieStore, org.apache.http.client.CredentialsProvider credentialsProvider, org.apache.http.client.config.RequestConfig defaultConfig)

Method Summary

Modifier and Type	Method	Description
<T> java.util.concurrent.Future<java.util.List<T>>	execute(org.apache.http.HttpHost target, java.util.List<? extends org.apache.http.nio.protocol.HttpAsyncRequestProducer> requestProducers, java.util.List<? extends org.apache.http.nio.protocol.HttpAsyncResponseConsumer<T>> responseConsumers, org.apache.http.protocol.HttpContext context, org.apache.http.concurrent.FutureCallback<java.util.List<T>> callback)	Initiates pipelined execution of a sequence of requests.
<T> java.util.concurrent.Future<T>	execute(org.apache.http.nio.protocol.HttpAsyncRequestProducer requestProducer, org.apache.http.nio.protocol.HttpAsyncResponseConsumer<T> responseConsumer, org.apache.http.protocol.HttpContext context, org.apache.http.concurrent.FutureCallback<T> callback)	Initiates asynchronous HTTP request execution using the given context.
private void	setupContext(org.apache.http.client.protocol.HttpClientContext context)

Methods inherited from class org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase

close, ensureRunning, isRunning, start

Methods inherited from class org.apache.http.impl.nio.client.CloseableHttpPipeliningClient

execute, execute, execute

Methods inherited from class org.apache.http.impl.nio.client.CloseableHttpAsyncClient

execute, execute, execute, execute, execute

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.http.nio.client.HttpAsyncClient

execute, execute, execute, execute, execute

Field Detail

log

private final org.apache.commons.logging.Log log

connmgr

private final NHttpClientConnectionManager connmgr

connReuseStrategy

private final org.apache.http.ConnectionReuseStrategy connReuseStrategy

keepaliveStrategy

private final org.apache.http.conn.ConnectionKeepAliveStrategy keepaliveStrategy

exec

private final InternalClientExec exec

cookieSpecRegistry

private final org.apache.http.config.Lookup<org.apache.http.cookie.CookieSpecProvider> cookieSpecRegistry

authSchemeRegistry

private final org.apache.http.config.Lookup<org.apache.http.auth.AuthSchemeProvider> authSchemeRegistry

cookieStore

private final org.apache.http.client.CookieStore cookieStore

credentialsProvider

private final org.apache.http.client.CredentialsProvider credentialsProvider

defaultConfig

private final org.apache.http.client.config.RequestConfig defaultConfig

Constructor Detail

InternalHttpAsyncClient

public InternalHttpAsyncClient(NHttpClientConnectionManager connmgr,
                               org.apache.http.ConnectionReuseStrategy connReuseStrategy,
                               org.apache.http.conn.ConnectionKeepAliveStrategy keepaliveStrategy,
                               java.util.concurrent.ThreadFactory threadFactory,
                               org.apache.http.nio.NHttpClientEventHandler handler,
                               InternalClientExec exec,
                               org.apache.http.config.Lookup<org.apache.http.cookie.CookieSpecProvider> cookieSpecRegistry,
                               org.apache.http.config.Lookup<org.apache.http.auth.AuthSchemeProvider> authSchemeRegistry,
                               org.apache.http.client.CookieStore cookieStore,
                               org.apache.http.client.CredentialsProvider credentialsProvider,
                               org.apache.http.client.config.RequestConfig defaultConfig)

Method Detail

setupContext

private void setupContext(org.apache.http.client.protocol.HttpClientContext context)

execute

public <T> java.util.concurrent.Future<T> execute(org.apache.http.nio.protocol.HttpAsyncRequestProducer requestProducer,
                                                  org.apache.http.nio.protocol.HttpAsyncResponseConsumer<T> responseConsumer,
                                                  org.apache.http.protocol.HttpContext context,
                                                  org.apache.http.concurrent.FutureCallback<T> callback)

Description copied from interface: HttpAsyncClient

Initiates asynchronous HTTP request execution using the given context.

The request producer passed to this method will be used to generate a request message and stream out its content without buffering it in memory. The response consumer passed to this method will be used to process a response message without buffering its content in memory.

Please note it may be unsafe to interact with the context instance while the request is still being executed.

Type Parameters:

T - the result type of request execution.

Parameters:

requestProducer - request producer callback.

responseConsumer - response consumer callaback.

context - HTTP context

callback - future callback.

Returns:

future representing pending completion of the operation.

execute

public <T> java.util.concurrent.Future<java.util.List<T>> execute(org.apache.http.HttpHost target,
                                                                  java.util.List<? extends org.apache.http.nio.protocol.HttpAsyncRequestProducer> requestProducers,
                                                                  java.util.List<? extends org.apache.http.nio.protocol.HttpAsyncResponseConsumer<T>> responseConsumers,
                                                                  org.apache.http.protocol.HttpContext context,
                                                                  org.apache.http.concurrent.FutureCallback<java.util.List<T>> callback)

Description copied from interface: HttpPipeliningClient

Initiates pipelined execution of a sequence of requests.

The request producers passed to this method will be used to generate a request message and stream out its content without buffering it in memory. The response consumers passed to this method will be used to process a response message without buffering its content in memory.

Please note it may be unsafe to interact with the context instance while the request is still being executed.

Type Parameters:

T - the result type of request execution.

Parameters:

target - the target host for the request.

requestProducers - list of request producers.

responseConsumers - list of response consumers.

context - HTTP context

callback - future callback.

Returns:

future representing pending completion of the operation.