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
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.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TcpInputStream
public TcpInputStream(InputStream delegate)
isStreaming
public boolean isStreaming()
setStreaming
public void setStreaming(boolean streaming)
Copyright © 2003-2009 MuleSource, Inc.. All Rights Reserved.