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	Description
static final int	DEFAULT_MAX_MESSAGE_SIZE	The default maximum message size when deserializing.
protected final LogAccessor	logger

Constructor Summary

Constructors

Constructor	Description
AbstractByteArraySerializer()

Method Summary

Modifier and Type	Method	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.Deserializer

deserialize, deserializeFromByteArray

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

serialize, serializeToByteArray

Field Details

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 Details

AbstractByteArraySerializer

public AbstractByteArraySerializer()

Method Details

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)