org.mule.transport.tcp.protocols

Class MuleMessageDirectProtocol

java.lang.Object

org.mule.transport.tcp.protocols.AbstractByteProtocol

org.mule.transport.tcp.protocols.DirectProtocol

org.mule.transport.tcp.protocols.MuleMessageDirectProtocol

All Implemented Interfaces:

org.mule.api.context.MuleContextAware, TcpProtocol

public class MuleMessageDirectProtocol
extends DirectProtocol
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 read until no more are (momentarily) available.

Field Summary

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
MuleMessageDirectProtocol()

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 data) Write the specified message to the output stream.

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

isRepeat, read, remaining

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

MuleMessageDirectProtocol

public MuleMessageDirectProtocol()

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 DirectProtocol

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 data)
           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

data - 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