org.springframework.integration.ip.tcp.serializer

Class ByteArrayRawSerializer

java.lang.Object

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

org.springframework.integration.ip.tcp.serializer.ByteArrayRawSerializer

All Implemented Interfaces:

org.springframework.core.serializer.Deserializer<byte[]>, org.springframework.core.serializer.Serializer<byte[]>

public class ByteArrayRawSerializer
extends AbstractByteArraySerializer

A byte array (de)serializer that does nothing with the payload; sends it raw. Message termination for assembly purposes is signaled by the client closing the connection. The serializer does not, itself, close the connection after writing the bytes.

Because the socket must be closed to indicate message end, this (de)serializer can only be used by uni-directional (non-collaborating) channel adapters, and not by gateways.

Since:

2.0.3

Author:

Gary Russell

Field Summary

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

logger, maxMessageSize

Constructor Summary

Constructors

Constructor and Description
ByteArrayRawSerializer()

Method Summary

Methods

Modifier and Type	Method and Description
byte[]	deserialize(java.io.InputStream inputStream)
void	serialize(byte[] bytes, java.io.OutputStream outputStream)

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

ByteArrayRawSerializer

public ByteArrayRawSerializer()

Method Detail

serialize

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

Throws:

java.io.IOException

deserialize

public byte[] deserialize(java.io.InputStream inputStream)
                   throws java.io.IOException

Throws:

java.io.IOException