Apache CXF API

org.apache.cxf.transport.http.netty.client
Class NettyHttpConduit

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.netty.client.NettyHttpConduit
All Implemented Interfaces:
PropertyChangeListener, EventListener, BusLifeCycleListener, Configurable, Assertor, Conduit, Observable

public class NettyHttpConduit
extends URLConnectionHTTPConduit
implements BusLifeCycleListener


Nested Class Summary
 class NettyHttpConduit.NettyWrappedOutputStream
           
 
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
NettyHttpConduit(Bus b, EndpointInfo ei, EndpointReferenceType t, NettyHttpConduitFactory conduitFactory)
           
 
Method Summary
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, 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

NettyHttpConduit

public NettyHttpConduit(Bus b,
                        EndpointInfo ei,
                        EndpointReferenceType t,
                        NettyHttpConduitFactory conduitFactory)
                 throws IOException
Throws:
IOException
Method Detail

getNettyHttpConduitFactory

public NettyHttpConduitFactory getNettyHttpConduitFactory()

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

initComplete

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

Specified by:
initComplete in interface BusLifeCycleListener

postShutdown

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

Specified by:
postShutdown in interface BusLifeCycleListener

preShutdown

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

Specified by:
preShutdown in interface BusLifeCycleListener

Apache CXF API

Apache CXF