org.springframework.integration.stream

Class ByteStreamReadingMessageSource

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.stream.ByteStreamReadingMessageSource

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, InitializingBean, ApplicationContextAware, MessageSource<byte[]>, NamedComponent

public class ByteStreamReadingMessageSource
extends IntegrationObjectSupport
implements MessageSource<byte[]>

A pollable source for receiving bytes from an InputStream.

Author:

Mark Fisher, Artem Bilan

Field Summary

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

logger

Constructor Summary

Constructors

Constructor and Description
ByteStreamReadingMessageSource(InputStream stream)
ByteStreamReadingMessageSource(InputStream stream, int bufferSize)

Method Summary

Methods

Modifier and Type	Method and Description
String	getComponentType() Subclasses may implement this method to provide component type information.
Message<byte[]>	receive() Retrieve the next available message from this source.
void	setBytesPerMessage(int bytesPerMessage)
void	setShouldTruncate(boolean shouldTruncate)

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

ByteStreamReadingMessageSource

public ByteStreamReadingMessageSource(InputStream stream)

ByteStreamReadingMessageSource

public ByteStreamReadingMessageSource(InputStream stream,
                              int bufferSize)

Method Detail

setBytesPerMessage

public void setBytesPerMessage(int bytesPerMessage)

setShouldTruncate

public void setShouldTruncate(boolean shouldTruncate)

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<byte[]> 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<byte[]>

Returns:

The messasge or null.