org.apache.cxf.transport.http.asyncclient
Class AsyncHTTPConduit
java.lang.Object
org.apache.cxf.transport.AbstractObservable
org.apache.cxf.transport.AbstractConduit
org.apache.cxf.transport.http.HTTPConduit
org.apache.cxf.transport.http.URLConnectionHTTPConduit
org.apache.cxf.transport.http.asyncclient.AsyncHTTPConduit
- All Implemented Interfaces:
- PropertyChangeListener, EventListener, Configurable, Assertor, Conduit, Observable
public class AsyncHTTPConduit
- extends URLConnectionHTTPConduit
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 |
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 |
USE_ASYNC
public static final String USE_ASYNC
- See Also:
- Constant Field Values
AsyncHTTPConduit
public AsyncHTTPConduit(Bus b,
EndpointInfo ei,
EndpointReferenceType t,
AsyncHTTPConduitFactory factory)
throws IOException
- Throws:
IOException
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