org.mule.transport.tcp.protocols

Class MuleMessageLengthProtocol

java.lang.Object

org.mule.transport.tcp.protocols.AbstractByteProtocol

org.mule.transport.tcp.protocols.DirectProtocol

org.mule.transport.tcp.protocols.LengthProtocol

org.mule.transport.tcp.protocols.MuleMessageLengthProtocol

All Implemented Interfaces:

org.mule.api.context.MuleContextAware, TcpProtocol

public class MuleMessageLengthProtocol
extends LengthProtocol
implements org.mule.api.context.MuleContextAware

This Protocol will send the actual Mule Message over the TCP channel, and in this way we are preserving any headers which might be needed, for example Correlation IDs in order to be able to aggregate messages after chunking. Data are encoded using LengthProtocol.

Field Summary

Fields inherited from class org.mule.transport.tcp.protocols.LengthProtocol

NO_MAX_LENGTH

Fields inherited from class org.mule.transport.tcp.protocols.DirectProtocol

bufferSize, UNLIMITED

Fields inherited from class org.mule.transport.tcp.protocols.AbstractByteProtocol

EOF, NO_STREAM, STREAM_OK

Constructor Summary

Constructors

Constructor and Description
MuleMessageLengthProtocol()

Method Summary

Methods

Modifier and Type	Method and Description
Object	read(InputStream is) Reads the input stream and returns a whole message.
void	setMuleContext(org.mule.api.MuleContext context)
void	write(OutputStream os, Object unused) Write the specified message to the output stream.

Methods inherited from class org.mule.transport.tcp.protocols.LengthProtocol

getMaxMessageLength, isRepeat, setMaxMessageLength, writeByteArray

Methods inherited from class org.mule.transport.tcp.protocols.DirectProtocol

read, remaining

Methods inherited from class org.mule.transport.tcp.protocols.AbstractByteProtocol

copy, copy, createResponse, isRethrowExceptionOnRead, nullEmptyArray, safeRead, safeRead, setObjectSerializer, setRethrowExceptionOnRead

Methods inherited from class java.lang.Object

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

Constructor Detail

MuleMessageLengthProtocol

public MuleMessageLengthProtocol()

Method Detail

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 LengthProtocol

Parameters:

is - the input stream

Returns:

an array of byte containing a full message

Throws:

IOException - if an exception occurs

write

public void write(OutputStream os,
         Object unused)
           throws IOException

Description copied from interface: TcpProtocol

Write the specified message to the output stream.

Specified by:

write in interface TcpProtocol

Overrides:

write in class AbstractByteProtocol

Parameters:

os - the output stream to write to

unused - the data to write

Throws:

IOException - if an exception occurs

setMuleContext

public void setMuleContext(org.mule.api.MuleContext context)

Specified by:

setMuleContext in interface org.mule.api.context.MuleContextAware