org.springframework.integration.ip.tcp.serializer

Class AbstractByteArraySerializer

java.lang.Object

org.springframework.integration.ip.tcp.serializer.AbstractByteArraySerializer

All Implemented Interfaces:

Aware, ApplicationEventPublisherAware, Deserializer<byte[]>, Serializer<byte[]>

Direct Known Subclasses:

AbstractPooledBufferByteArraySerializer, ByteArrayLengthHeaderSerializer

public abstract class AbstractByteArraySerializer
extends Object
implements Serializer<byte[]>, Deserializer<byte[]>, ApplicationEventPublisherAware

Base class for (de)serializers that provide a mechanism to reconstruct a byte array from an arbitrary stream.

Since:

2.0

Author:

Gary Russell, Artme Bilan

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_MAX_MESSAGE_SIZE The default maximum message size when deserializing.
protected LogAccessor	logger

Constructor Summary

Constructors

Constructor and Description
AbstractByteArraySerializer()

Method Summary

Modifier and Type	Method and Description
protected void	checkClosure(int bite)
int	getMaxMessageSize() The maximum supported message size for this serializer.
protected void	publishEvent(Exception cause, byte[] buffer, int offset)
void	setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
void	setMaxMessageSize(int maxMessageSize) The maximum supported message size for this serializer.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.core.serializer.Serializer

serialize, serializeToByteArray

Methods inherited from interface org.springframework.core.serializer.Deserializer

deserialize, deserializeFromByteArray

Field Detail

DEFAULT_MAX_MESSAGE_SIZE

public static final int DEFAULT_MAX_MESSAGE_SIZE

The default maximum message size when deserializing.

Since:

5.1.3

See Also:

Constant Field Values

logger

protected final LogAccessor logger

Constructor Detail

AbstractByteArraySerializer

public AbstractByteArraySerializer()

Method Detail

getMaxMessageSize

public int getMaxMessageSize()

The maximum supported message size for this serializer. Default 2048.

Returns:

The max message size.

setMaxMessageSize

public void setMaxMessageSize(int maxMessageSize)

The maximum supported message size for this serializer. Default 2048.

Parameters:

maxMessageSize - The max message size.

setApplicationEventPublisher

public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)

Specified by:

setApplicationEventPublisher in interface ApplicationEventPublisherAware

checkClosure

protected void checkClosure(int bite)
                     throws IOException

Throws:

IOException

publishEvent

protected void publishEvent(Exception cause,
                            byte[] buffer,
                            int offset)