org.springframework.integration.ip.tcp.serializer

Class ByteArraySingleTerminatorSerializer

java.lang.Object

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

org.springframework.integration.ip.tcp.serializer.AbstractPooledBufferByteArraySerializer

org.springframework.integration.ip.tcp.serializer.ByteArraySingleTerminatorSerializer

All Implemented Interfaces:

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

Direct Known Subclasses:

ByteArrayLfSerializer

public class ByteArraySingleTerminatorSerializer
extends AbstractPooledBufferByteArraySerializer

Reads data in an InputStream to a byte[]; data must be terminated by a single byte (not included in resulting byte[]). Writes a byte[] to an OutputStream and adds the terminator.

Since:

2.2

Author:

Gary Russell, Artem Bilan

Field Summary

Fields inherited from class org.springframework.integration.ip.tcp.serializer.AbstractByteArraySerializer

DEFAULT_MAX_MESSAGE_SIZE, logger

Constructor Summary

Constructors

Constructor and Description
ByteArraySingleTerminatorSerializer(byte delimiter)

Method Summary

Modifier and Type	Method and Description
protected byte[]	doDeserialize(InputStream inputStream, byte[] buffer) Reads the data in the inputStream to a byte[].
void	serialize(byte[] bytes, OutputStream outputStream) Writes the byte[] to the stream and appends the terminator.

Methods inherited from class org.springframework.integration.ip.tcp.serializer.AbstractPooledBufferByteArraySerializer

copyToSizedArray, deserialize, setPoolSize, setPoolWaitTimeout

Methods inherited from class org.springframework.integration.ip.tcp.serializer.AbstractByteArraySerializer

checkClosure, getMaxMessageSize, publishEvent, setApplicationEventPublisher, setMaxMessageSize

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

serializeToByteArray

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

deserializeFromByteArray

Constructor Detail

ByteArraySingleTerminatorSerializer

public ByteArraySingleTerminatorSerializer(byte delimiter)

Method Detail

doDeserialize

protected byte[] doDeserialize(InputStream inputStream,
                               byte[] buffer)
                        throws IOException

Reads the data in the inputStream to a byte[]. Data must be terminated by a single byte. Throws a SoftEndOfStreamException if the stream is closed immediately after the terminator (i.e. no data is in the process of being read).

Specified by:

doDeserialize in class AbstractPooledBufferByteArraySerializer

Parameters:

inputStream - the input stream.

buffer - the raw working buffer (maxMessageSize).

Returns:

the decoded bytes.

Throws:

IOException - an io exception.

serialize

public void serialize(byte[] bytes,
                      OutputStream outputStream)
               throws IOException

Writes the byte[] to the stream and appends the terminator.

Throws:

IOException