Class CharacterStreamReadingMessageSource

java.lang.Object

org.springframework.integration.util.AbstractExpressionEvaluator

org.springframework.integration.endpoint.AbstractMessageSource<String>

org.springframework.integration.stream.inbound.CharacterStreamReadingMessageSource

org.springframework.integration.stream.CharacterStreamReadingMessageSource

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationEventPublisherAware, MessageSource<String>, IntegrationPattern, NamedComponent, IntegrationInboundManagement, IntegrationManagement

@Deprecated(forRemoval=true,
            since="7.0")
public class CharacterStreamReadingMessageSource
extends CharacterStreamReadingMessageSource

Deprecated, for removal: This API element is subject to removal in a future version.

since 7.0 in favor of CharacterStreamReadingMessageSource

A pollable source for Readers.

Author:

Mark Fisher, Gary Russell, Artem Bilan, Christian Tzolov, Ngoc Nhan

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields inherited from class org.springframework.integration.util.AbstractExpressionEvaluator

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Constructor Summary

Constructors

Constructor	Description
CharacterStreamReadingMessageSource(Reader reader)	Deprecated, for removal: This API element is subject to removal in a future version. Construct an instance with the provider reader.
CharacterStreamReadingMessageSource(Reader reader, int bufferSize)	Deprecated, for removal: This API element is subject to removal in a future version. Construct an instance with the provider reader and buffer size.
CharacterStreamReadingMessageSource(Reader reader, int bufferSize, boolean blockToDetectEOF)	Deprecated, for removal: This API element is subject to removal in a future version. Construct an instance with the provided reader and buffer size.

Method Summary

Modifier and Type	Method	Description
static CharacterStreamReadingMessageSource	stdin()	Deprecated, for removal: This API element is subject to removal in a future version. Create a source that reads from System.in.
static CharacterStreamReadingMessageSource	stdin(String charsetName)	Deprecated, for removal: This API element is subject to removal in a future version. Create a source that reads from System.in.
static CharacterStreamReadingMessageSource	stdinPipe()	Deprecated, for removal: This API element is subject to removal in a future version. Create a source that reads from System.in.
static CharacterStreamReadingMessageSource	stdinPipe(String charsetName)	Deprecated, for removal: This API element is subject to removal in a future version. Create a source that reads from System.in.

Methods inherited from class org.springframework.integration.stream.inbound.CharacterStreamReadingMessageSource

doReceive, getComponentType, setApplicationEventPublisher

Methods inherited from class org.springframework.integration.endpoint.AbstractMessageSource

buildMessage, destroy, getComponentName, getManagedName, getManagedType, getOverrides, isLoggingEnabled, receive, registerMetricsCaptor, setBeanName, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedType

Methods inherited from class org.springframework.integration.util.AbstractExpressionEvaluator

afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, onInit, setBeanFactory, setConversionService, setSimpleEvaluationContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.integration.support.management.IntegrationManagement

getThisAs, isObserved, registerObservationRegistry

Methods inherited from interface org.springframework.integration.core.MessageSource

getIntegrationPatternType

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getBeanName

Constructor Details

CharacterStreamReadingMessageSource

public CharacterStreamReadingMessageSource(Reader reader)

Deprecated, for removal: This API element is subject to removal in a future version.

Construct an instance with the provider reader. AbstractMessageSource.receive() will return null when the reader is not ready.

Parameters:

reader - the reader.

CharacterStreamReadingMessageSource

public CharacterStreamReadingMessageSource(Reader reader,
 int bufferSize)

Deprecated, for removal: This API element is subject to removal in a future version.

Construct an instance with the provider reader and buffer size. AbstractMessageSource.receive() will return null when the reader is not ready.

Parameters:

reader - the reader.

bufferSize - the buffer size.

CharacterStreamReadingMessageSource

public CharacterStreamReadingMessageSource(Reader reader,
 int bufferSize,
 boolean blockToDetectEOF)

Deprecated, for removal: This API element is subject to removal in a future version.

Construct an instance with the provided reader and buffer size. When blockToDetectEOF is false, AbstractMessageSource.receive() will return null when the reader is not ready. When it is true, the thread will block until data is available; when the underlying stream is closed, a StreamClosedEvent is published to inform the application via an ApplicationListener. This can be useful, for example, when piping stdin

     cat foo.txt | java -jar my.jar
 

or

     java -jar my.jar < foo.txt
 

Parameters:

reader - the reader.

bufferSize - the buffer size; if negative use the default in BufferedReader.

blockToDetectEOF - true to block the thread until data is available and publish a StreamClosedEvent at EOF.

Since:

5.0

Method Details

stdin

public static CharacterStreamReadingMessageSource stdin()

Deprecated, for removal: This API element is subject to removal in a future version.

Create a source that reads from System.in. EOF will not be detected.

Returns:

the stream.

stdin

public static CharacterStreamReadingMessageSource stdin(String charsetName)

Deprecated, for removal: This API element is subject to removal in a future version.

Create a source that reads from System.in. EOF will not be detected.

Parameters:

charsetName - the charset to use when converting bytes to String.

Returns:

the stream.

stdinPipe

public static CharacterStreamReadingMessageSource stdinPipe()

Deprecated, for removal: This API element is subject to removal in a future version.

Create a source that reads from System.in. EOF will be detected and the application context closed.

Returns:

the stream.

Since:

5.0

See Also:

• CharacterStreamReadingMessageSource(Reader, int, boolean)

stdinPipe

public static CharacterStreamReadingMessageSource stdinPipe(String charsetName)

Deprecated, for removal: This API element is subject to removal in a future version.

Create a source that reads from System.in. EOF will be detected and the application context closed.

Parameters:

charsetName - the charset to use when converting bytes to String.

Returns:

the stream.

Since:

5.0

See Also:

• CharacterStreamReadingMessageSource(Reader, int, boolean)