org.springframework.integration.stream
Class CharacterStreamReadingMessageSource

java.lang.Object
  extended by org.springframework.integration.stream.CharacterStreamReadingMessageSource
All Implemented Interfaces:
MessageSource<java.lang.String>

public class CharacterStreamReadingMessageSource
extends java.lang.Object
implements MessageSource<java.lang.String>

A pollable source for Readers.

Author:
Mark Fisher

Constructor Summary
CharacterStreamReadingMessageSource(java.io.Reader reader)
           
CharacterStreamReadingMessageSource(java.io.Reader reader, int bufferSize)
           
 
Method Summary
 StringMessage receive()
          Retrieve the next available message from this source.
static CharacterStreamReadingMessageSource stdin()
           
static CharacterStreamReadingMessageSource stdin(java.lang.String charsetName)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

CharacterStreamReadingMessageSource

public CharacterStreamReadingMessageSource(java.io.Reader reader)

CharacterStreamReadingMessageSource

public CharacterStreamReadingMessageSource(java.io.Reader reader,
                                           int bufferSize)
Method Detail

receive

public StringMessage 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<java.lang.String>

stdin

public static final CharacterStreamReadingMessageSource stdin()

stdin

public static final CharacterStreamReadingMessageSource stdin(java.lang.String charsetName)