public class NettyHttpConduit extends URLConnectionHTTPConduit implements BusLifeCycleListener
| Modifier and Type | Class and Description |
|---|---|
class |
NettyHttpConduit.NettyWrappedOutputStream |
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 |
|---|
NettyHttpConduit(Bus b,
EndpointInfo ei,
EndpointReferenceType t,
NettyHttpConduitFactory conduitFactory) |
| Modifier and Type | Method and Description |
|---|---|
protected OutputStream |
createOutputStream(Message message,
boolean needToCacheRequest,
boolean isChunking,
int chunkThreshold) |
NettyHttpConduitFactory |
getNettyHttpConduitFactory() |
void |
initComplete()
Invoked when the
Bus has been initialized. |
void |
postShutdown()
Invoked after the
Bus is shutdown. |
void |
preShutdown()
Invoked before the
Bus is shutdown. |
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 NettyHttpConduit(Bus b, EndpointInfo ei, EndpointReferenceType t, NettyHttpConduitFactory conduitFactory) throws IOException
IOExceptionpublic NettyHttpConduitFactory getNettyHttpConduitFactory()
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 void initComplete()
BusLifeCycleListenerBus has been initialized.initComplete in interface BusLifeCycleListenerpublic void postShutdown()
BusLifeCycleListenerBus is shutdown.postShutdown in interface BusLifeCycleListenerpublic void preShutdown()
BusLifeCycleListenerBus is shutdown.preShutdown in interface BusLifeCycleListenerApache CXF