org.springframework.integration.ip.tcp.serializer

Class ByteArraySingleTerminatorSerializer

java.lang.Object

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

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

All Implemented Interfaces:

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

Direct Known Subclasses:

ByteArrayLfSerializer

public class ByteArraySingleTerminatorSerializer
extends AbstractByteArraySerializer

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

Field Summary

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

logger, maxMessageSize

Constructor Summary

Constructors

Constructor and Description
ByteArraySingleTerminatorSerializer(byte delimiter)

Method Summary

Methods

Modifier and Type	Method and Description
byte[]	deserialize(InputStream inputStream) 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.AbstractByteArraySerializer

checkClosure, copyToSizedArray, getMaxMessageSize, setMaxMessageSize

Methods inherited from class java.lang.Object

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

Constructor Detail

ByteArraySingleTerminatorSerializer

public ByteArraySingleTerminatorSerializer(byte delimiter)

Method Detail

deserialize

public byte[] deserialize(InputStream inputStream)
                   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).

Throws:

IOException

serialize

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

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

Throws:

IOException