org.springframework.integration.stream
Class ByteStreamReadingMessageSource
java.lang.Object
org.springframework.integration.stream.ByteStreamReadingMessageSource
- All Implemented Interfaces:
- org.springframework.integration.core.MessageSource<byte[]>
public class ByteStreamReadingMessageSource
- extends java.lang.Object
- implements org.springframework.integration.core.MessageSource<byte[]>
A pollable source for receiving bytes from an InputStream.
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ByteStreamReadingMessageSource
public ByteStreamReadingMessageSource(java.io.InputStream stream)
ByteStreamReadingMessageSource
public ByteStreamReadingMessageSource(java.io.InputStream stream,
int bufferSize)
setBytesPerMessage
public void setBytesPerMessage(int bytesPerMessage)
setShouldTruncate
public void setShouldTruncate(boolean shouldTruncate)
receive
public org.springframework.integration.Message<byte[]> receive()
- Specified by:
receive in interface org.springframework.integration.core.MessageSource<byte[]>