org.springframework.integration.stream

Class CharacterStreamReadingMessageSource

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.stream.CharacterStreamReadingMessageSource

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, InitializingBean, ApplicationContextAware, MessageSource<String>, NamedComponent

public class CharacterStreamReadingMessageSource
extends IntegrationObjectSupport
implements MessageSource<String>

A pollable source for Readers.

Author:

Mark Fisher

Field Summary

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

logger

Constructor Summary

Constructors

Constructor and Description
CharacterStreamReadingMessageSource(Reader reader)
CharacterStreamReadingMessageSource(Reader reader, int bufferSize)

Method Summary

Methods

Modifier and Type	Method and Description
String	getComponentType() Subclasses may implement this method to provide component type information.
Message<String>	receive() Retrieve the next available message from this source.
static CharacterStreamReadingMessageSource	stdin()
static CharacterStreamReadingMessageSource	stdin(String charsetName)

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, onInit, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

CharacterStreamReadingMessageSource

public CharacterStreamReadingMessageSource(Reader reader)

CharacterStreamReadingMessageSource

public CharacterStreamReadingMessageSource(Reader reader,
                                   int bufferSize)

Method Detail

getComponentType

public 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<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<String>

Returns:

The messasge or null.

stdin

public static final CharacterStreamReadingMessageSource stdin()

stdin

public static final CharacterStreamReadingMessageSource stdin(String charsetName)