org.mule.transport.tcp.protocols

Class MuleMessageEOFProtocol

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.MuleMessageEOFProtocol

All Implemented Interfaces:

MuleContextAware, TcpProtocol

public class MuleMessageEOFProtocol
extends EOFProtocol
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 read until the client closes the channel.

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

Method Summary

Methods

Modifier and Type	Method and Description
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.EOFProtocol

isRepeat

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, writeByteArray

Methods inherited from class java.lang.Object

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

Constructor Detail

MuleMessageEOFProtocol

public MuleMessageEOFProtocol()

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 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(MuleContext context)

Specified by:

setMuleContext in interface MuleContextAware