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

Class NettyHttpConduit.NettyWrappedOutputStream

java.lang.Object

java.io.OutputStream

org.apache.cxf.io.AbstractWrappedOutputStream

org.apache.cxf.io.AbstractThresholdOutputStream

org.apache.cxf.transport.http.HTTPConduit.WrappedOutputStream

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

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

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

Constructors

Modifier	Constructor and Description
protected	NettyWrappedOutputStream(Message message, boolean possibleRetransmit, boolean isChunking, int chunkThreshold, String conduitName, URI url)

Method Summary

Modifier and Type	Method and Description
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	handleNoOutput()
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, doProcessResponseCode, getMethod, handleHeadersTrustCaching, handleHttpRetryException, handleResponse, handleResponseInternal, handleResponseOnWorkqueue, handleRetransmits, makeTrustDecision, onFirstWrite, processRetransmit, propagateConduit, 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

NettyWrappedOutputStream

protected 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

handleNoOutput

protected void handleNoOutput()
                       throws IOException

Overrides:

handleNoOutput 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)