org.apache.cxf.transport.websocket.ahc

Class AhcWebSocketConduit.AhcWebSocketWrappedOutputStream

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.websocket.ahc.AhcWebSocketConduit.AhcWebSocketWrappedOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

Enclosing class:

AhcWebSocketConduit

public class AhcWebSocketConduit.AhcWebSocketWrappedOutputStream
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	AhcWebSocketWrappedOutputStream(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()
protected HttpsURLConnectionInfo	getHttpsURLConnectionInfo()
protected InputStream	getInputStream()
protected InputStream	getPartialResponse()
protected int	getResponseCode()
protected String	getResponseMessage()
protected void	handleNoOutput()
protected void	handleResponseAsync()
protected void	retransmitStream()
protected void	setFixedLengthStreamingMode(int i)
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

AhcWebSocketWrappedOutputStream

protected AhcWebSocketWrappedOutputStream(Message message,
                                          boolean possibleRetransmit,
                                          boolean isChunking,
                                          int chunkThreshold,
                                          String conduitName,
                                          URI url)

Method Detail

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

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

connect

protected void connect()