org.mule.transport.tcp.protocols
Class MuleMessageSafeProtocol

java.lang.Object
  org.mule.transport.tcp.protocols.SafeProtocol
      org.mule.transport.tcp.protocols.MuleMessageSafeProtocol

All Implemented Interfaces:

MuleContextAware, TcpProtocol

public class MuleMessageSafeProtocol
extends SafeProtocol
implements 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 SafeProtocol.

Field Summary

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

COOKIE

Constructor Summary

MuleMessageSafeProtocol()

Method Summary

Object	read(InputStream is) Reads the input stream and returns a whole message.
void	setMuleContext(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.SafeProtocol

createResponse, setMaxMessageLength

Methods inherited from class java.lang.Object

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

Constructor Detail

MuleMessageSafeProtocol

public MuleMessageSafeProtocol()

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 SafeProtocol

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 SafeProtocol

Parameters:

os - the output stream to write to

unused - the data to write

Throws:

IOException - if an exception occurs

setMuleContext

public void setMuleContext(MuleContext context)

Specified by:

setMuleContext in interface MuleContextAware