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

Class CustomClassLoadingLengthProtocol

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

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

All Implemented Interfaces:

TcpProtocol

@XmlHints(allowTopLevelDefinition=true)
public class CustomClassLoadingLengthProtocol
extends LengthProtocol

A length protocol that uses a specific class loader to load objects from streams

Since:

2.2.6

Field Summary

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

LENGTH_EXCEEDED

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

Method Summary

Modifier and Type	Method and Description
ClassLoader	getClassLoader()
InputStream	read(InputStream is) It consumes the socket InputStream according to this#consume(InputStream) and then wraps the result into a ByteArrayInputStream.
void	setClassLoader(ClassLoader classLoader)

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

isRepeat, writeByteArray

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

consume, remaining, write

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

copy, copy, nullIfEmptyArray, safeRead, safeRead, setObjectSerializer

Methods inherited from class java.lang.Object

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

Constructor Detail

CustomClassLoadingLengthProtocol

public CustomClassLoadingLengthProtocol()

Method Detail

read

public InputStream read(InputStream is)
                 throws IOException

Description copied from class: LengthProtocol

It consumes the socket InputStream according to this#consume(InputStream) and then wraps the result into a ByteArrayInputStream.

Specified by:

read in interface TcpProtocol

Overrides:

read in class LengthProtocol

Parameters:

is - the input stream

Returns:

null if this#consume(InputStream) throws an IOException and rethrowExceptionOnRead is not set

Throws:

IOException - is thrown if rethrowExceptionOnRead is set

getClassLoader

public ClassLoader getClassLoader()

setClassLoader

public void setClassLoader(ClassLoader classLoader)