org.apache.cxf.transport.http.asyncclient
Class AsyncHTTPConduitFactory
java.lang.Object
org.apache.cxf.transport.http.asyncclient.AsyncHTTPConduitFactory
- All Implemented Interfaces:
- HTTPConduitFactory
public class AsyncHTTPConduitFactory
- extends Object
- implements HTTPConduitFactory
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TCP_NODELAY
public static final String TCP_NODELAY
- See Also:
- Constant Field Values
SO_KEEPALIVE
public static final String SO_KEEPALIVE
- See Also:
- Constant Field Values
SO_LINGER
public static final String SO_LINGER
- See Also:
- Constant Field Values
SO_TIMEOUT
public static final String SO_TIMEOUT
- See Also:
- Constant Field Values
MAX_CONNECTIONS
public static final String MAX_CONNECTIONS
- See Also:
- Constant Field Values
MAX_PER_HOST_CONNECTIONS
public static final String MAX_PER_HOST_CONNECTIONS
- See Also:
- Constant Field Values
CONNECTION_TTL
public static final String CONNECTION_TTL
- See Also:
- Constant Field Values
THREAD_COUNT
public static final String THREAD_COUNT
- See Also:
- Constant Field Values
INTEREST_OP_QUEUED
public static final String INTEREST_OP_QUEUED
- See Also:
- Constant Field Values
SELECT_INTERVAL
public static final String SELECT_INTERVAL
- See Also:
- Constant Field Values
USE_POLICY
public static final String USE_POLICY
- See Also:
- Constant Field Values
AsyncHTTPConduitFactory
public AsyncHTTPConduitFactory(Map<String,Object> conf)
AsyncHTTPConduitFactory
public AsyncHTTPConduitFactory(Bus b)
getUseAsyncPolicy
public AsyncHTTPConduitFactory.UseAsyncPolicy getUseAsyncPolicy()
update
public void update(Map<String,Object> props)
isShutdown
public boolean isShutdown()
createConduit
public HTTPConduit createConduit(HTTPTransportFactory f,
Bus bus,
EndpointInfo localInfo,
EndpointReferenceType target)
throws IOException
- Specified by:
createConduit in interface HTTPConduitFactory
- Throws:
IOException
createConduit
public HTTPConduit createConduit(Bus bus,
EndpointInfo localInfo,
EndpointReferenceType target)
throws IOException
- Throws:
IOException
shutdown
public void shutdown()
setupNIOClient
public void setupNIOClient(HTTPClientPolicy clientPolicy)
throws org.apache.http.nio.reactor.IOReactorException
- Throws:
org.apache.http.nio.reactor.IOReactorException
createClient
public org.apache.http.impl.nio.client.CloseableHttpAsyncClient createClient(AsyncHTTPConduit c)
throws IOException
- Throws:
IOException
Apache CXF