public class AsyncHTTPConduit extends URLConnectionHTTPConduit
| Modifier and Type | Class and Description |
|---|---|
class |
AsyncHTTPConduit.AsyncWrappedOutputStream |
HTTPConduit.InterposedMessageObserver, HTTPConduit.WrappedOutputStream| Modifier and Type | Field and Description |
|---|---|
static String |
USE_ASYNC |
connectionFactoryauthorizationPolicy, authSupplier, bus, certConstraints, clientSidePolicy, cookies, defaultEndpointURI, defaultEndpointURIString, endpointInfo, fromEndpointReferenceType, KEY_HTTP_CONNECTION, KEY_HTTP_CONNECTION_ADDRESS, LOG, proxyAuthorizationPolicy, proxyAuthSupplier, proxyFactory, tlsClientParameters, trustDecidertargetincomingObserver| Constructor and Description |
|---|
AsyncHTTPConduit(Bus b,
EndpointInfo ei,
EndpointReferenceType t,
AsyncHTTPConduitFactory factory) |
| Modifier and Type | Method and Description |
|---|---|
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,
Address address,
HTTPClientPolicy csPolicy) |
closeassertMessage, 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, setTrustDecidergetTarget, toStringactivate, deactivate, getMessageObserver, getTargetReference, getTargetReference, setMessageObserverclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetMessageObserver, setMessageObserverpublic static final String USE_ASYNC
public AsyncHTTPConduit(Bus b, EndpointInfo ei, EndpointReferenceType t, AsyncHTTPConduitFactory factory) throws IOException
IOExceptionpublic org.apache.http.impl.nio.client.CloseableHttpAsyncClient getHttpAsyncClient()
throws IOException
IOExceptionpublic AsyncHTTPConduitFactory getAsyncHTTPConduitFactory()
protected void setupConnection(Message message, Address address, HTTPClientPolicy csPolicy) throws IOException
setupConnection in class URLConnectionHTTPConduitIOExceptionprotected OutputStream createOutputStream(Message message, boolean needToCacheRequest, boolean isChunking, int chunkThreshold) throws IOException
createOutputStream in class URLConnectionHTTPConduitIOExceptionpublic SSLContext getSSLContext(TLSClientParameters tlsClientParameters) throws GeneralSecurityException
GeneralSecurityExceptionpublic void initializeSSLEngine(SSLContext sslcontext, SSLEngine sslengine)
protected static KeyManager[] getKeyManagersWithCertAlias(TLSClientParameters tlsClientParameters, KeyManager[] keyManagers) throws GeneralSecurityException
GeneralSecurityExceptionApache CXF