Apache CXF API

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

java.lang.Object
  extended by org.apache.cxf.transport.AbstractObservable
      extended by org.apache.cxf.transport.AbstractConduit
          extended by org.apache.cxf.transport.http.HTTPConduit
              extended by org.apache.cxf.transport.http.URLConnectionHTTPConduit
                  extended by org.apache.cxf.transport.http.asyncclient.AsyncHTTPConduit
All Implemented Interfaces:
PropertyChangeListener, EventListener, Configurable, Assertor, Conduit, Observable

public class AsyncHTTPConduit
extends URLConnectionHTTPConduit


Nested Class Summary
 class AsyncHTTPConduit.AsyncWrappedOutputStream
           
 
Nested classes/interfaces inherited from class org.apache.cxf.transport.http.HTTPConduit
HTTPConduit.InterposedMessageObserver, HTTPConduit.WrappedOutputStream
 
Field Summary
static String USE_ASYNC
           
 
Fields inherited from class org.apache.cxf.transport.http.URLConnectionHTTPConduit
connectionFactory
 
Fields inherited from class org.apache.cxf.transport.http.HTTPConduit
authorizationPolicy, authSupplier, bus, certConstraints, clientSidePolicy, cookies, defaultEndpointURI, defaultEndpointURIString, endpointInfo, fromEndpointReferenceType, KEY_HTTP_CONNECTION, LOG, proxyAuthorizationPolicy, proxyAuthSupplier, proxyFactory, tlsClientParameters, trustDecider
 
Fields inherited from class org.apache.cxf.transport.AbstractConduit
target
 
Fields inherited from class org.apache.cxf.transport.AbstractObservable
incomingObserver
 
Constructor Summary
AsyncHTTPConduit(Bus b, EndpointInfo ei, EndpointReferenceType t, AsyncHTTPConduitFactory factory)
           
 
Method Summary
protected  OutputStream createOutputStream(Message message, boolean needToCacheRequest, boolean isChunking, int chunkThreshold)
           
 AsyncHTTPConduitFactory getAsyncHTTPConduitFactory()
           
 org.apache.http.impl.nio.client.CloseableHttpAsyncClient getHttpAsyncClient()
           
protected static KeyManager[] getKeyManagersWithCertAlias(TLSClientParameters tlsClientParameters, KeyManager[] keyManagers)
           
 SSLContext getSSLContext(TLSClientParameters tlsClientParameters)
           
 void initializeSSLEngine(SSLContext sslcontext, SSLEngine sslengine)
           
protected  void setupConnection(Message message, URI uri, HTTPClientPolicy csPolicy)
           
 
Methods inherited from class org.apache.cxf.transport.http.URLConnectionHTTPConduit
close
 
Methods inherited from class org.apache.cxf.transport.http.HTTPConduit
assertMessage, canAssert, close, determineConnectionTimeout, determineReceiveTimeout, extractLocation, finalizeConfig, getAddress, getAuthorization, getAuthSupplier, getBeanName, getClient, getClient, getConduitName, getCookies, getEffectiveAuthPolicy, getLogger, getProxyAuthorization, getProxyAuthSupplier, getTlsClientParameters, getTrustDecider, getURI, getURI, isChunkingSupported, prepare, propertyChange, setAuthorization, setAuthSupplier, setClient, setHeadersByAuthorizationPolicy, setProxyAuthorization, setProxyAuthSupplier, setTlsClientParameters, setTrustDecider
 
Methods inherited from class org.apache.cxf.transport.AbstractConduit
getTarget, toString
 
Methods inherited from class org.apache.cxf.transport.AbstractObservable
activate, deactivate, getMessageObserver, getTargetReference, getTargetReference, setMessageObserver
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.cxf.transport.Observable
getMessageObserver, setMessageObserver
 

Field Detail

USE_ASYNC

public static final String USE_ASYNC
See Also:
Constant Field Values
Constructor Detail

AsyncHTTPConduit

public AsyncHTTPConduit(Bus b,
                        EndpointInfo ei,
                        EndpointReferenceType t,
                        AsyncHTTPConduitFactory factory)
                 throws IOException
Throws:
IOException
Method Detail

getHttpAsyncClient

public org.apache.http.impl.nio.client.CloseableHttpAsyncClient getHttpAsyncClient()
                                                                            throws IOException
Throws:
IOException

getAsyncHTTPConduitFactory

public AsyncHTTPConduitFactory getAsyncHTTPConduitFactory()

setupConnection

protected void setupConnection(Message message,
                               URI uri,
                               HTTPClientPolicy csPolicy)
                        throws IOException
Overrides:
setupConnection in class URLConnectionHTTPConduit
Throws:
IOException

createOutputStream

protected OutputStream createOutputStream(Message message,
                                          boolean needToCacheRequest,
                                          boolean isChunking,
                                          int chunkThreshold)
                                   throws IOException
Overrides:
createOutputStream in class URLConnectionHTTPConduit
Throws:
IOException

getSSLContext

public SSLContext getSSLContext(TLSClientParameters tlsClientParameters)
                         throws GeneralSecurityException
Throws:
GeneralSecurityException

initializeSSLEngine

public void initializeSSLEngine(SSLContext sslcontext,
                                SSLEngine sslengine)

getKeyManagersWithCertAlias

protected static KeyManager[] getKeyManagersWithCertAlias(TLSClientParameters tlsClientParameters,
                                                          KeyManager[] keyManagers)
                                                   throws GeneralSecurityException
Throws:
GeneralSecurityException

Apache CXF API

Apache CXF