org.mule.transport.tcp.protocols
Class XmlMessageEOFProtocol

java.lang.Object
  org.mule.transport.tcp.protocols.AbstractByteProtocol
      org.mule.transport.tcp.protocols.XmlMessageProtocol
          org.mule.transport.tcp.protocols.XmlMessageEOFProtocol

All Implemented Interfaces:

TcpProtocol

public class XmlMessageEOFProtocol
extends XmlMessageProtocol

Extend XmlMessageProtocol to continue reading until either a new message or EOF is found.

Field Summary

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

EOF, NO_STREAM, STREAM_OK

Constructor Summary

XmlMessageEOFProtocol()

Method Summary

protected boolean

isRepeat(int patternIndex, int len, int available) Continue reading til EOF or new document found

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

read

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

XmlMessageEOFProtocol

public XmlMessageEOFProtocol()

Method Detail

isRepeat

protected boolean isRepeat(int patternIndex,
                           int len,
                           int available)

Continue reading til EOF or new document found

Overrides:

isRepeat in class XmlMessageProtocol

Parameters:

patternIndex - The index of the xml tag (or -1 if the next message not found)

len - The amount of data read this loop (or -1 if EOF)

available - The amount of data available to read

Returns:

true if the read should continue

See Also:

XmlMessageEOFProtocol