public class AsyncHTTPConduitFactory extends Object implements HTTPConduitFactory
Modifier and Type | Class and Description |
---|---|
static class |
AsyncHTTPConduitFactory.UseAsyncPolicy |
Modifier and Type | Field and Description |
---|---|
static String |
CONNECTION_TTL |
static String |
INTEREST_OP_QUEUED |
static String |
MAX_CONNECTIONS |
static String |
MAX_PER_HOST_CONNECTIONS |
static String |
SELECT_INTERVAL |
static String |
SO_KEEPALIVE |
static String |
SO_LINGER |
static String |
SO_TIMEOUT |
static String |
TCP_NODELAY |
static String |
THREAD_COUNT |
static String |
USE_POLICY |
Constructor and Description |
---|
AsyncHTTPConduitFactory(Bus b) |
AsyncHTTPConduitFactory(Map<String,Object> conf) |
Modifier and Type | Method and Description |
---|---|
protected void |
adaptClientBuilder(org.apache.http.impl.nio.client.HttpAsyncClientBuilder httpAsyncClientBuilder) |
org.apache.http.impl.nio.client.CloseableHttpAsyncClient |
createClient(AsyncHTTPConduit c) |
HTTPConduit |
createConduit(Bus bus,
EndpointInfo localInfo,
EndpointReferenceType target) |
HTTPConduit |
createConduit(HTTPTransportFactory f,
Bus bus,
EndpointInfo localInfo,
EndpointReferenceType target) |
AsyncHTTPConduitFactory.UseAsyncPolicy |
getUseAsyncPolicy() |
boolean |
isShutdown() |
void |
setupNIOClient(HTTPClientPolicy clientPolicy) |
void |
shutdown() |
void |
update(Map<String,Object> props) |
public static final String TCP_NODELAY
public static final String SO_KEEPALIVE
public static final String SO_LINGER
public static final String SO_TIMEOUT
public static final String MAX_CONNECTIONS
public static final String MAX_PER_HOST_CONNECTIONS
public static final String CONNECTION_TTL
public static final String THREAD_COUNT
public static final String INTEREST_OP_QUEUED
public static final String SELECT_INTERVAL
public static final String USE_POLICY
public AsyncHTTPConduitFactory(Bus b)
public AsyncHTTPConduitFactory.UseAsyncPolicy getUseAsyncPolicy()
public boolean isShutdown()
public HTTPConduit createConduit(HTTPTransportFactory f, Bus bus, EndpointInfo localInfo, EndpointReferenceType target) throws IOException
createConduit
in interface HTTPConduitFactory
IOException
public HTTPConduit createConduit(Bus bus, EndpointInfo localInfo, EndpointReferenceType target) throws IOException
IOException
public void shutdown()
public void setupNIOClient(HTTPClientPolicy clientPolicy) throws org.apache.http.nio.reactor.IOReactorException
org.apache.http.nio.reactor.IOReactorException
protected void adaptClientBuilder(org.apache.http.impl.nio.client.HttpAsyncClientBuilder httpAsyncClientBuilder)
public org.apache.http.impl.nio.client.CloseableHttpAsyncClient createClient(AsyncHTTPConduit c) throws IOException
IOException
Apache CXF