org.springframework.integration.stream
Class ByteStreamReadingMessageSource

java.lang.Object
  extended by 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.


Constructor Summary
ByteStreamReadingMessageSource(java.io.InputStream stream)
           
ByteStreamReadingMessageSource(java.io.InputStream stream, int bufferSize)
           
 
Method Summary
 org.springframework.integration.Message<byte[]> receive()
           
 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 org.springframework.integration.Message<byte[]> receive()
Specified by:
receive in interface org.springframework.integration.core.MessageSource<byte[]>