Spring Integration

org.springframework.integration.stream
Class CharacterStreamReadingMessageSource

java.lang.Object
  extended by org.springframework.integration.context.IntegrationObjectSupport
      extended by org.springframework.integration.stream.CharacterStreamReadingMessageSource
All Implemented Interfaces:
org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, NamedComponent, MessageSource<java.lang.String>

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

A pollable source for Readers.

Author:
Mark Fisher

Field Summary
 
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport
logger
 
Constructor Summary
CharacterStreamReadingMessageSource(java.io.Reader reader)
           
CharacterStreamReadingMessageSource(java.io.Reader reader, int bufferSize)
           
 
Method Summary
 java.lang.String getComponentType()
          Subclasses may implement this method to provide component type information.
 Message<java.lang.String> receive()
          Retrieve the next available message from this source.
static CharacterStreamReadingMessageSource stdin()
           
static CharacterStreamReadingMessageSource stdin(java.lang.String charsetName)
           
 
Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, getBeanFactory, getComponentName, getConversionService, getTaskScheduler, onInit, setBeanFactory, setBeanName, setComponentName, setConversionService, setTaskScheduler, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

CharacterStreamReadingMessageSource

public CharacterStreamReadingMessageSource(java.io.Reader reader)

CharacterStreamReadingMessageSource

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

getComponentType

public java.lang.String getComponentType()
Description copied from class: IntegrationObjectSupport
Subclasses may implement this method to provide component type information.

Specified by:
getComponentType in interface NamedComponent
Overrides:
getComponentType in class IntegrationObjectSupport

receive

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

Spring Integration