org.springframework.integration.ip.tcp.serializer

Class ByteArrayElasticRawDeserializer

java.lang.Object

org.springframework.integration.ip.tcp.serializer.ByteArrayElasticRawDeserializer

All Implemented Interfaces:

Deserializer<byte[]>

public class ByteArrayElasticRawDeserializer
extends Object
implements Deserializer<byte[]>

A deserializer that uses a ByteArrayOutputStream instead of a fixed buffer, allowing the buffer to grow as needed. Completion is indicated by the sender closing the socket.

Since:

5.0

Author:

Gary Russell

Constructor Summary

Constructors

Constructor and Description
ByteArrayElasticRawDeserializer() Construct an instance that uses ByteArrayOutputStreams with an initial buffer size of 32;
ByteArrayElasticRawDeserializer(int initialBufferSize) Construct an instance that uses ByteArrayOutputStreams with the provided initial buffer size.

Method Summary

Modifier and Type	Method and Description
byte[]	deserialize(InputStream inputStream)

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

deserializeFromByteArray

Constructor Detail

ByteArrayElasticRawDeserializer

public ByteArrayElasticRawDeserializer()

Construct an instance that uses ByteArrayOutputStreams with an initial buffer size of 32;

ByteArrayElasticRawDeserializer

public ByteArrayElasticRawDeserializer(int initialBufferSize)

Construct an instance that uses ByteArrayOutputStreams with the provided initial buffer size.

Parameters:

initialBufferSize - the initial buffer size.

Method Detail

deserialize

public byte[] deserialize(InputStream inputStream)
                   throws IOException

Specified by:

deserialize in interface Deserializer<byte[]>

Throws:

IOException