Class ByteArrayCrLfSerializer
java.lang.Object
org.springframework.integration.ip.tcp.serializer.AbstractByteArraySerializer
org.springframework.integration.ip.tcp.serializer.AbstractPooledBufferByteArraySerializer
org.springframework.integration.ip.tcp.serializer.ByteArrayCrLfSerializer
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.context.ApplicationEventPublisherAware,org.springframework.core.serializer.Deserializer<byte[]>,org.springframework.core.serializer.Serializer<byte[]>
public class ByteArrayCrLfSerializer extends AbstractPooledBufferByteArraySerializer
Reads data in an InputStream to a byte[]; data must be terminated by \r\n
(not included in resulting byte[]).
Writes a byte[] to an OutputStream and adds \r\n.
- Since:
- 2.0
-
Field Summary
Fields Modifier and Type Field Description static ByteArrayCrLfSerializerINSTANCEA single reusable instance.Fields inherited from class org.springframework.integration.ip.tcp.serializer.AbstractByteArraySerializer
DEFAULT_MAX_MESSAGE_SIZE, logger -
Constructor Summary
Constructors Constructor Description ByteArrayCrLfSerializer() -
Method Summary
Modifier and Type Method Description byte[]doDeserialize(java.io.InputStream inputStream, byte[] buffer)Reads the data in the inputStream to a byte[].intfillToCrLf(java.io.InputStream inputStream, byte[] buffer)voidserialize(byte[] bytes, java.io.OutputStream outputStream)Writes the byte[] to the stream and appends \r\n.Methods inherited from class org.springframework.integration.ip.tcp.serializer.AbstractPooledBufferByteArraySerializer
copyToSizedArray, deserialize, setPoolSize, setPoolWaitTimeoutMethods inherited from class org.springframework.integration.ip.tcp.serializer.AbstractByteArraySerializer
checkClosure, getMaxMessageSize, publishEvent, setApplicationEventPublisher, setMaxMessageSizeMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Field Details
-
INSTANCE
A single reusable instance.
-
-
Constructor Details
-
ByteArrayCrLfSerializer
public ByteArrayCrLfSerializer()
-
-
Method Details
-
doDeserialize
public byte[] doDeserialize(java.io.InputStream inputStream, byte[] buffer) throws java.io.IOExceptionReads the data in the inputStream to a byte[]. Data must be terminated by CRLF (\r\n). Throws aSoftEndOfStreamExceptionif the stream is closed immediately after the \r\n (i.e. no data is in the process of being read).- Specified by:
doDeserializein classAbstractPooledBufferByteArraySerializer- Parameters:
inputStream- the input stream.buffer- the raw working buffer (maxMessageSize).- Returns:
- the decoded bytes.
- Throws:
java.io.IOException- an io exception.
-
fillToCrLf
public int fillToCrLf(java.io.InputStream inputStream, byte[] buffer) throws java.io.IOException- Throws:
java.io.IOException
-
serialize
public void serialize(byte[] bytes, java.io.OutputStream outputStream) throws java.io.IOExceptionWrites the byte[] to the stream and appends \r\n.- Throws:
java.io.IOException
-