public class ByteStreamReadingMessageSource extends Object implements MessageSource<byte[]>
InputStream
.Constructor and Description |
---|
ByteStreamReadingMessageSource(InputStream stream) |
ByteStreamReadingMessageSource(InputStream stream,
int bufferSize) |
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) |
public ByteStreamReadingMessageSource(InputStream stream)
public ByteStreamReadingMessageSource(InputStream stream, int bufferSize)
public void setBytesPerMessage(int bytesPerMessage)
public void setShouldTruncate(boolean shouldTruncate)
public Message<byte[]> receive()
MessageSource
null
if no message is available.receive
in interface MessageSource<byte[]>
Copyright © 2015. All rights reserved.