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

Class EOFProtocol

java.lang.Object

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

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

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

All Implemented Interfaces:

TcpProtocol

Direct Known Subclasses:

StreamingProtocol

@Alias(value="eof-protocol")
 @XmlHints(allowTopLevelDefinition=true)
public class EOFProtocol
extends DirectProtocol

This protocol is an application level TcpProtocol that does nothing. Reading is terminated by the stream being closed by the client.

Since:

4.0

Field Summary

Fields inherited from class org.mule.extension.socket.api.connection.tcp.protocol.DirectProtocol

bufferSize, UNLIMITED

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

Method Summary

Modifier and Type	Method and Description
protected boolean	isRepeat(int len, int available) Repeat until EOF

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

consume, read, remaining, 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

EOFProtocol

public EOFProtocol()

Method Detail

isRepeat

protected boolean isRepeat(int len,
                           int available)

Repeat until EOF

Overrides:

isRepeat in class DirectProtocol

Parameters:

len - Amount transferred last call (-1 on EOF or socket error)

available - Amount available

Returns:

true if the transfer should continue