org.springframework.integration.stream
Class CharacterStreamReadingMessageSource

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