public class NettyHttpConduit.NettyWrappedOutputStream extends HTTPConduit.WrappedOutputStream
cachedStream, cachingForRetransmission, chunking, conduitName, outMessage, urlbuffer, thresholdallowFlush, wrappedStream, written| Modifier | Constructor and Description |
|---|---|
protected |
NettyHttpConduit.NettyWrappedOutputStream(Message message,
boolean possibleRetransmit,
boolean isChunking,
int chunkThreshold,
String conduitName,
URI url) |
| 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 |
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() |
authorizationRetransmit, close, getMethod, handleHeadersTrustCaching, handleHttpRetryException, handleNoOutput, handleResponse, handleResponseInternal, handleResponseOnWorkqueue, handleRetransmits, makeTrustDecision, onFirstWrite, processRetransmit, propagateConduit, redirectRetransmit, retransmit, thresholdNotReachedunBuffer, write, writeallowFlush, flush, writeprotected io.netty.buffer.ByteBuf getOutBuffer()
protected io.netty.handler.codec.http.HttpResponse getHttpResponse()
throws IOException
IOExceptionprotected io.netty.handler.codec.http.HttpContent getHttpResponseContent()
throws IOException
IOExceptionprotected io.netty.channel.Channel getChannel()
throws IOException
IOExceptionprotected void setupWrappedStream()
throws IOException
setupWrappedStream in class HTTPConduit.WrappedOutputStreamIOExceptionprotected TLSClientParameters findTLSClientParameters()
protected void connect(boolean output)
protected HttpsURLConnectionInfo getHttpsURLConnectionInfo() throws IOException
getHttpsURLConnectionInfo in class HTTPConduit.WrappedOutputStreamIOExceptionprotected void setProtocolHeaders()
throws IOException
setProtocolHeaders in class HTTPConduit.WrappedOutputStreamIOExceptionprotected void setFixedLengthStreamingMode(int i)
setFixedLengthStreamingMode in class HTTPConduit.WrappedOutputStreamprotected int getResponseCode()
throws IOException
getResponseCode in class HTTPConduit.WrappedOutputStreamIOExceptionprotected String getResponseMessage() throws IOException
getResponseMessage in class HTTPConduit.WrappedOutputStreamIOExceptionprotected void updateResponseHeaders(Message inMessage) throws IOException
updateResponseHeaders in class HTTPConduit.WrappedOutputStreamIOExceptionprotected void handleResponseAsync()
throws IOException
handleResponseAsync in class HTTPConduit.WrappedOutputStreamIOExceptionprotected void closeInputStream()
throws IOException
closeInputStream in class HTTPConduit.WrappedOutputStreamIOExceptionprotected boolean usingProxy()
usingProxy in class HTTPConduit.WrappedOutputStreamprotected InputStream getInputStream() throws IOException
getInputStream in class HTTPConduit.WrappedOutputStreamIOExceptionprotected InputStream getPartialResponse() throws IOException
getPartialResponse in class HTTPConduit.WrappedOutputStreamIOExceptionprotected void setupNewConnection(String newURL) throws IOException
setupNewConnection in class HTTPConduit.WrappedOutputStreamIOExceptionprotected void retransmitStream()
throws IOException
retransmitStream in class HTTPConduit.WrappedOutputStreamIOExceptionprotected void updateCookiesBeforeRetransmit()
throws IOException
updateCookiesBeforeRetransmit in class HTTPConduit.WrappedOutputStreamIOExceptionpublic void thresholdReached()
throws IOException
thresholdReached in class AbstractThresholdOutputStreamIOExceptionprotected void setHttpResponse(io.netty.handler.codec.http.HttpResponse r)
protected void setException(Throwable ex)
protected void setChannel(io.netty.channel.Channel ch)
Apache CXF