org.springframework.integration.stream

Class ByteStreamReadingMessageSource

java.lang.Object

org.springframework.integration.stream.ByteStreamReadingMessageSource

All Implemented Interfaces:

MessageSource<byte[]>

public class ByteStreamReadingMessageSource
extends java.lang.Object
implements MessageSource<byte[]>

A pollable source for receiving bytes from an InputStream.

Author:

Mark Fisher

Constructor Summary

Constructors

Constructor and Description
ByteStreamReadingMessageSource(java.io.InputStream stream)
ByteStreamReadingMessageSource(java.io.InputStream stream, int bufferSize)

Method Summary

Methods

Modifier and Type	Method and Description
Message<byte[]>	receive() Retrieve the next available message from this source.
void	setBytesPerMessage(int bytesPerMessage)
void	setShouldTruncate(boolean shouldTruncate)

Methods inherited from class java.lang.Object

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

Constructor Detail

ByteStreamReadingMessageSource

public ByteStreamReadingMessageSource(java.io.InputStream stream)

ByteStreamReadingMessageSource

public ByteStreamReadingMessageSource(java.io.InputStream stream,
                              int bufferSize)

Method Detail

setBytesPerMessage

public void setBytesPerMessage(int bytesPerMessage)

setShouldTruncate

public void setShouldTruncate(boolean shouldTruncate)

receive

public Message<byte[]> receive()

Description copied from interface: MessageSource

Retrieve the next available message from this source. Returns null if no message is available.

Specified by:

receive in interface MessageSource<byte[]>