Apache CXF API

org.apache.cxf.transport.http.asyncclient
Class AsyncHTTPConduitFactory

java.lang.Object
  extended by org.apache.cxf.transport.http.asyncclient.AsyncHTTPConduitFactory
All Implemented Interfaces:
HTTPConduitFactory

public class AsyncHTTPConduitFactory
extends Object
implements HTTPConduitFactory


Nested Class Summary
static class AsyncHTTPConduitFactory.UseAsyncPolicy
           
 
Field Summary
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 Summary
AsyncHTTPConduitFactory(Bus b)
           
AsyncHTTPConduitFactory(Map<String,Object> conf)
           
 
Method Summary
 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)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

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
Constructor Detail

AsyncHTTPConduitFactory

public AsyncHTTPConduitFactory(Map<String,Object> conf)

AsyncHTTPConduitFactory

public AsyncHTTPConduitFactory(Bus b)
Method Detail

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 API

Apache CXF