org.apache.cxf.binding.soap.tcp
Class SoapTcpOutputStream

java.lang.Object
  java.io.OutputStream
      org.apache.cxf.io.AbstractWrappedOutputStream
          org.apache.cxf.io.AbstractThresholdOutputStream
              org.apache.cxf.binding.soap.tcp.SoapTcpOutputStream

All Implemented Interfaces:

Closeable, Flushable

public class SoapTcpOutputStream
extends AbstractThresholdOutputStream

SoapTCPOutPutStream is OutputStream for sending message in SOAP/TCP protocol. It sends single message in one or more SOAP/TCP frames.

Field Summary

static int

CHUNK_SIZE

Fields inherited from class org.apache.cxf.io.AbstractThresholdOutputStream

buffer, threshold

Fields inherited from class org.apache.cxf.io.AbstractWrappedOutputStream

wrappedStream, written

Constructor Summary

SoapTcpOutputStream(InputStream inStream, OutputStream outStream, Message message, String targetWsURI, MessageObserver incomingObserver)

SoapTcpOutputStream(InputStream inStream, OutputStream outStream, Message message, String targetWsURI, MessageObserver incomingObserver, int chunkSize)

Method Summary

void	close()
protected void	onFirstWrite()
void	thresholdNotReached()
void	thresholdReached()

Methods inherited from class org.apache.cxf.io.AbstractThresholdOutputStream

unBuffer, write, write

Methods inherited from class org.apache.cxf.io.AbstractWrappedOutputStream

flush, write

Methods inherited from class java.lang.Object

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

Field Detail

CHUNK_SIZE

public static final int CHUNK_SIZE

See Also:

Constant Field Values

Constructor Detail

SoapTcpOutputStream

public SoapTcpOutputStream(InputStream inStream,
                           OutputStream outStream,
                           Message message,
                           String targetWsURI,
                           MessageObserver incomingObserver)

SoapTcpOutputStream

public SoapTcpOutputStream(InputStream inStream,
                           OutputStream outStream,
                           Message message,
                           String targetWsURI,
                           MessageObserver incomingObserver,
                           int chunkSize)

Method Detail

thresholdNotReached

public void thresholdNotReached()
                         throws IOException

Specified by:

thresholdNotReached in class AbstractThresholdOutputStream

Throws:

IOException

thresholdReached

public void thresholdReached()
                      throws IOException

Specified by:

thresholdReached in class AbstractThresholdOutputStream

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Overrides:

close in class AbstractThresholdOutputStream

Throws:

IOException

onFirstWrite

protected void onFirstWrite()
                     throws IOException

Overrides:

onFirstWrite in class AbstractWrappedOutputStream

Throws:

IOException