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

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

Enclosing class:

AhcWebSocketConduit

public class AhcWebSocketConduit.AhcWebSocketWrappedOutputStream
extends org.apache.cxf.io.AbstractThresholdOutputStream

Field Summary

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	Description
protected	AhcWebSocketWrappedOutputStream(org.apache.cxf.message.Message message, boolean possibleRetransmit, boolean isChunking, int chunkThreshold, String conduitName, URI url)

Method Summary

Modifier and Type	Method	Description
protected void	closeInputStream()
protected void	connect()
protected org.apache.cxf.transport.https.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(org.apache.cxf.message.Message inMessage)
protected boolean	usingProxy()

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.io.OutputStream

nullOutputStream

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AhcWebSocketWrappedOutputStream

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

Method Details

setupWrappedStream

protected void setupWrappedStream()
                           throws IOException

Throws:

IOException

handleNoOutput

protected void handleNoOutput()
                       throws IOException

Throws:

IOException

getHttpsURLConnectionInfo

protected org.apache.cxf.transport.https.HttpsURLConnectionInfo getHttpsURLConnectionInfo()
                                                                                   throws IOException

Throws:

IOException

setProtocolHeaders

protected void setProtocolHeaders()
                           throws IOException

Throws:

IOException

setFixedLengthStreamingMode

protected void setFixedLengthStreamingMode(int i)

getResponseCode

protected int getResponseCode()
                       throws IOException

Throws:

IOException

getResponseMessage

protected String getResponseMessage()
                             throws IOException

Throws:

IOException

updateResponseHeaders

protected void updateResponseHeaders(org.apache.cxf.message.Message inMessage)
                              throws IOException

Throws:

IOException

handleResponseAsync

protected void handleResponseAsync()
                            throws IOException

Throws:

IOException

closeInputStream

protected void closeInputStream()
                         throws IOException

Throws:

IOException

usingProxy

protected boolean usingProxy()

getInputStream

protected InputStream getInputStream()
                              throws IOException

Throws:

IOException

getPartialResponse

protected InputStream getPartialResponse()
                                  throws IOException

Throws:

IOException

setupNewConnection

protected void setupNewConnection(String newURL)
                           throws IOException

Throws:

IOException

retransmitStream

protected void retransmitStream()
                         throws IOException

Throws:

IOException

updateCookiesBeforeRetransmit

protected void updateCookiesBeforeRetransmit()
                                      throws IOException

Throws:

IOException

thresholdReached

public void thresholdReached()
                      throws IOException

Specified by:

thresholdReached in class org.apache.cxf.io.AbstractThresholdOutputStream

Throws:

IOException

connect

protected void connect()