org.mule.extension.socket.api.connection.tcp.protocol

Class XmlMessageEOFProtocol

java.lang.Object

org.mule.extension.socket.api.connection.tcp.protocol.AbstractByteProtocol

org.mule.extension.socket.api.connection.tcp.protocol.XmlMessageProtocol

org.mule.extension.socket.api.connection.tcp.protocol.XmlMessageEOFProtocol

All Implemented Interfaces:

TcpProtocol

@Alias(value="xml-message-eof-protocol")
 @XmlHints(allowTopLevelDefinition=true)
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.extension.socket.api.connection.tcp.protocol.AbstractByteProtocol

EOF, NO_MAX_LENGTH, NO_STREAM, objectSerializer, rethrowExceptionOnRead, STREAM_OK, streamOk

Constructor Summary

Constructors

Constructor and Description
XmlMessageEOFProtocol()

Method Summary

Modifier and Type	Method and Description
protected boolean	isRepeat(int patternIndex, int len, int available) Continue reading til EOF or new document found

Methods inherited from class org.mule.extension.socket.api.connection.tcp.protocol.XmlMessageProtocol

read, write

Methods inherited from class org.mule.extension.socket.api.connection.tcp.protocol.AbstractByteProtocol

copy, copy, nullIfEmptyArray, safeRead, safeRead, setObjectSerializer, 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