org.mule.transport.tcp

Class TcpInputStream

java.lang.Object

java.io.InputStream

org.mule.model.streaming.DelegatingInputStream

org.mule.transport.tcp.TcpInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class TcpInputStream
extends DelegatingInputStream

The TcpMessageDispatcher and the TcpMessageReceiver use this class as the input parameter to the read() method on the TcpProtocol interface. If you wish to simply use the InputStream as the message payload that you're reading in, you just call tcpInputStream.setStreaming(true) so that Mule knows to stop listening for more messages on that stream.

Constructor Summary

Constructors

Constructor and Description
TcpInputStream(InputStream delegate)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	isStreaming()
void	setStreaming(boolean streaming)

Methods inherited from class org.mule.model.streaming.DelegatingInputStream

available, close, mark, markSupported, read, read, read, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpInputStream

public TcpInputStream(InputStream delegate)

Method Detail

isStreaming

public boolean isStreaming()

setStreaming

public void setStreaming(boolean streaming)