public class AsyncHTTPConduitFactory extends Object implements BusLifeCycleListener, 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 |
|---|---|
org.apache.http.impl.nio.client.DefaultHttpAsyncClient |
createClient(AsyncHTTPConduit c) |
HTTPConduit |
createConduit(Bus bus,
EndpointInfo localInfo,
EndpointReferenceType target) |
HTTPConduit |
createConduit(HTTPTransportFactory f,
EndpointInfo localInfo,
EndpointReferenceType target) |
org.apache.http.protocol.BasicHttpProcessor |
getDefaultHttpProcessor() |
AsyncHTTPConduitFactory.UseAsyncPolicy |
getUseAsyncPolicy() |
void |
initComplete()
Invoked when the
Bus has been initialized. |
boolean |
isShutdown() |
void |
postShutdown()
Invoked after the
Bus is shutdown. |
void |
preShutdown()
Invoked before the
Bus is shutdown. |
void |
setBus(Bus b) |
void |
setupNIOClient() |
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 org.apache.http.protocol.BasicHttpProcessor getDefaultHttpProcessor()
public AsyncHTTPConduitFactory.UseAsyncPolicy getUseAsyncPolicy()
public boolean isShutdown()
public HTTPConduit createConduit(HTTPTransportFactory f, EndpointInfo localInfo, EndpointReferenceType target) throws IOException
createConduit in interface HTTPConduitFactoryIOExceptionpublic HTTPConduit createConduit(Bus bus, EndpointInfo localInfo, EndpointReferenceType target) throws IOException
IOExceptionpublic void setBus(Bus b)
public void initComplete()
BusLifeCycleListenerBus has been initialized.initComplete in interface BusLifeCycleListenerpublic void preShutdown()
BusLifeCycleListenerBus is shutdown.preShutdown in interface BusLifeCycleListenerpublic void postShutdown()
BusLifeCycleListenerBus is shutdown.postShutdown in interface BusLifeCycleListenerpublic void shutdown()
public void setupNIOClient()
throws org.apache.http.nio.reactor.IOReactorException
org.apache.http.nio.reactor.IOReactorExceptionpublic org.apache.http.impl.nio.client.DefaultHttpAsyncClient createClient(AsyncHTTPConduit c) throws IOException
IOExceptionApache CXF