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:
BusLifeCycleListener, HTTPConduitFactory

public class AsyncHTTPConduitFactory
extends Object
implements BusLifeCycleListener, 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.DefaultHttpAsyncClient createClient(AsyncHTTPConduit c)
           
 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)
           
 
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

getDefaultHttpProcessor

public org.apache.http.protocol.BasicHttpProcessor getDefaultHttpProcessor()

getUseAsyncPolicy

public AsyncHTTPConduitFactory.UseAsyncPolicy getUseAsyncPolicy()

update

public void update(Map<String,Object> props)

isShutdown

public boolean isShutdown()

createConduit

public HTTPConduit createConduit(HTTPTransportFactory f,
                                 EndpointInfo localInfo,
                                 EndpointReferenceType target)
                          throws IOException
Specified by:
createConduit in interface HTTPConduitFactory
Throws:
IOException

setBus

public void setBus(Bus b)

initComplete

public void initComplete()
Description copied from interface: BusLifeCycleListener
Invoked when the Bus has been initialized.

Specified by:
initComplete in interface BusLifeCycleListener

preShutdown

public void preShutdown()
Description copied from interface: BusLifeCycleListener
Invoked before the Bus is shutdown.

Specified by:
preShutdown in interface BusLifeCycleListener

postShutdown

public void postShutdown()
Description copied from interface: BusLifeCycleListener
Invoked after the Bus is shutdown.

Specified by:
postShutdown in interface BusLifeCycleListener

shutdown

public void shutdown()

setupNIOClient

public void setupNIOClient()
                    throws org.apache.http.nio.reactor.IOReactorException
Throws:
org.apache.http.nio.reactor.IOReactorException

createClient

public org.apache.http.impl.nio.client.DefaultHttpAsyncClient createClient(AsyncHTTPConduit c)
                                                                    throws IOException
Throws:
IOException

Apache CXF API

Apache CXF