org.mule.transport.tcp
Class TcpInputStream

java.lang.Object
  extended by java.io.InputStream
      extended by org.mule.model.streaming.DelegatingInputStream
          extended by 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.


Constructor Summary
TcpInputStream(InputStream delegate)
           
 
Method Summary
 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)


Copyright © 2003-2009 MuleSource, Inc.. All Rights Reserved.