Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
Apache CXF API
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

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

java.lang.Object
  extended by java.io.OutputStream
      extended by org.apache.cxf.io.AbstractWrappedOutputStream
          extended by org.apache.cxf.io.AbstractThresholdOutputStream
              extended by org.apache.cxf.transport.http.HTTPConduit.WrappedOutputStream
                  extended by org.apache.cxf.transport.http.netty.client.NettyHttpConduit.NettyWrappedOutputStream
All Implemented Interfaces:
Closeable, Flushable
Enclosing class:
NettyHttpConduit
public class NettyHttpConduit.NettyWrappedOutputStream
extends HTTPConduit.WrappedOutputStream

Field Summary
 
Fields inherited from class org.apache.cxf.transport.http.HTTPConduit.WrappedOutputStream
cachedStream, cachingForRetransmission, chunking, conduitName, outMessage, url
 
Fields inherited from class org.apache.cxf.io.AbstractThresholdOutputStream
buffer, threshold
 
Fields inherited from class org.apache.cxf.io.AbstractWrappedOutputStream
allowFlush, wrappedStream, written
 
Constructor Summary
protected NettyHttpConduit.NettyWrappedOutputStream(Message message, boolean possibleRetransmit, boolean isChunking, int chunkThreshold, String conduitName, URI url)
           
 
Method Summary
protected  void closeInputStream()
           
protected  void connect(boolean output)
           
protected  TLSClientParameters findTLSClientParameters()
           
protected  io.netty.channel.Channel getChannel()
           
protected  io.netty.handler.codec.http.HttpResponse getHttpResponse()
           
protected  io.netty.handler.codec.http.HttpContent getHttpResponseContent()
           
protected  HttpsURLConnectionInfo getHttpsURLConnectionInfo()
           
protected  InputStream getInputStream()
           
protected  io.netty.buffer.ByteBuf getOutBuffer()
           
protected  InputStream getPartialResponse()
           
protected  int getResponseCode()
           
protected  String getResponseMessage()
           
protected  void handleResponseAsync()
           
protected  void retransmitStream()
           
protected  void setChannel(io.netty.channel.Channel ch)
           
protected  void setException(Throwable ex)
           
protected  void setFixedLengthStreamingMode(int i)
           
protected  void setHttpResponse(io.netty.handler.codec.http.HttpResponse r)
           
protected  void setProtocolHeaders()
           
protected  void setupNewConnection(String newURL)
           
protected  void setupWrappedStream()
           
 void thresholdReached()
           
protected  void updateCookiesBeforeRetransmit()
           
protected  void updateResponseHeaders(Message inMessage)
           
protected  boolean usingProxy()
           
 
Methods inherited from class org.apache.cxf.transport.http.HTTPConduit.WrappedOutputStream
authorizationRetransmit, close, getMethod, handleHeadersTrustCaching, handleHttpRetryException, handleNoOutput, handleResponse, handleResponseInternal, handleResponseOnWorkqueue, handleRetransmits, makeTrustDecision, onFirstWrite, processRetransmit, redirectRetransmit, retransmit, thresholdNotReached
 
Methods inherited from class org.apache.cxf.io.AbstractThresholdOutputStream
unBuffer, write, write
 
Methods inherited from class org.apache.cxf.io.AbstractWrappedOutputStream
allowFlush, flush, write
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

NettyHttpConduit.NettyWrappedOutputStream

protected NettyHttpConduit.NettyWrappedOutputStream(Message message,
                                                    boolean possibleRetransmit,
                                                    boolean isChunking,
                                                    int chunkThreshold,
                                                    String conduitName,
                                                    URI url)
Method Detail

getOutBuffer

protected io.netty.buffer.ByteBuf getOutBuffer()

getHttpResponse

protected io.netty.handler.codec.http.HttpResponse getHttpResponse()
                                                            throws IOException
Throws:
IOException

getHttpResponseContent

protected io.netty.handler.codec.http.HttpContent getHttpResponseContent()
                                                                  throws IOException
Throws:
IOException

getChannel

protected io.netty.channel.Channel getChannel()
                                       throws IOException
Throws:
IOException

setupWrappedStream

protected void setupWrappedStream()
                           throws IOException
Specified by:
setupWrappedStream in class HTTPConduit.WrappedOutputStream
Throws:
IOException

findTLSClientParameters

protected TLSClientParameters findTLSClientParameters()

connect

protected void connect(boolean output)

getHttpsURLConnectionInfo

protected HttpsURLConnectionInfo getHttpsURLConnectionInfo()
                                                    throws IOException
Specified by:
getHttpsURLConnectionInfo in class HTTPConduit.WrappedOutputStream
Throws:
IOException

setProtocolHeaders

protected void setProtocolHeaders()
                           throws IOException
Specified by:
setProtocolHeaders in class HTTPConduit.WrappedOutputStream
Throws:
IOException

setFixedLengthStreamingMode

protected void setFixedLengthStreamingMode(int i)
Specified by:
setFixedLengthStreamingMode in class HTTPConduit.WrappedOutputStream

getResponseCode

protected int getResponseCode()
                       throws IOException
Specified by:
getResponseCode in class HTTPConduit.WrappedOutputStream
Throws:
IOException

getResponseMessage

protected String getResponseMessage()
                             throws IOException
Specified by:
getResponseMessage in class HTTPConduit.WrappedOutputStream
Throws:
IOException

updateResponseHeaders

protected void updateResponseHeaders(Message inMessage)
                              throws IOException
Specified by:
updateResponseHeaders in class HTTPConduit.WrappedOutputStream
Throws:
IOException

handleResponseAsync

protected void handleResponseAsync()
                            throws IOException
Specified by:
handleResponseAsync in class HTTPConduit.WrappedOutputStream
Throws:
IOException

closeInputStream

protected void closeInputStream()
                         throws IOException
Specified by:
closeInputStream in class HTTPConduit.WrappedOutputStream
Throws:
IOException

usingProxy

protected boolean usingProxy()
Specified by:
usingProxy in class HTTPConduit.WrappedOutputStream

getInputStream

protected InputStream getInputStream()
                              throws IOException
Specified by:
getInputStream in class HTTPConduit.WrappedOutputStream
Throws:
IOException

getPartialResponse

protected InputStream getPartialResponse()
                                  throws IOException
Specified by:
getPartialResponse in class HTTPConduit.WrappedOutputStream
Throws:
IOException

setupNewConnection

protected void setupNewConnection(String newURL)
                           throws IOException
Specified by:
setupNewConnection in class HTTPConduit.WrappedOutputStream
Throws:
IOException

retransmitStream

protected void retransmitStream()
                         throws IOException
Specified by:
retransmitStream in class HTTPConduit.WrappedOutputStream
Throws:
IOException

updateCookiesBeforeRetransmit

protected void updateCookiesBeforeRetransmit()
                                      throws IOException
Specified by:
updateCookiesBeforeRetransmit in class HTTPConduit.WrappedOutputStream
Throws:
IOException

thresholdReached

public void thresholdReached()
                      throws IOException
Specified by:
thresholdReached in class AbstractThresholdOutputStream
Throws:
IOException

setHttpResponse

protected void setHttpResponse(io.netty.handler.codec.http.HttpResponse r)

setException

protected void setException(Throwable ex)

setChannel

protected void setChannel(io.netty.channel.Channel ch)
Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
Apache CXF API
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD
Apache CXF