org.mule.transport.tcp.protocols
Class StreamingProtocol
java.lang.Object
org.mule.transport.tcp.protocols.AbstractByteProtocol
org.mule.transport.tcp.protocols.DirectProtocol
org.mule.transport.tcp.protocols.EOFProtocol
org.mule.transport.tcp.protocols.StreamingProtocol
- All Implemented Interfaces:
- TcpProtocol
public class StreamingProtocol
- extends EOFProtocol
- implements TcpProtocol
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
StreamingProtocol
public StreamingProtocol()
read
public Object read(InputStream is)
throws IOException
- Description copied from interface:
TcpProtocol
- Reads the input stream and returns a whole message.
- Specified by:
read
in interface TcpProtocol
- Overrides:
read
in class DirectProtocol
- Parameters:
is
- the input stream
- Returns:
- an array of byte containing a full message
- Throws:
IOException
- if an exception occurs
copyStream
protected void copyStream(InputStream is,
OutputStream os)
throws IOException
- Parameters:
is
- os
-
- Throws:
IOException
getLimit
protected int getLimit()
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.