Class ByteStreamReadingMessageSource
java.lang.Object
org.springframework.integration.util.AbstractExpressionEvaluator
org.springframework.integration.endpoint.AbstractMessageSource<byte[]>
org.springframework.integration.stream.ByteStreamReadingMessageSource
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.InitializingBean,org.springframework.integration.core.MessageSource<byte[]>,org.springframework.integration.IntegrationPattern,org.springframework.integration.support.context.NamedComponent,org.springframework.integration.support.management.IntegrationInboundManagement,org.springframework.integration.support.management.IntegrationManagement
public class ByteStreamReadingMessageSource
extends org.springframework.integration.endpoint.AbstractMessageSource<byte[]>
A pollable source for receiving bytes from an
InputStream.-
Nested Class Summary
-
Field Summary
-
Constructor Summary
Constructors Constructor Description ByteStreamReadingMessageSource(java.io.InputStream stream)ByteStreamReadingMessageSource(java.io.InputStream stream, int bufferSize) -
Method Summary
Modifier and Type Method Description protected byte[]doReceive()java.lang.StringgetComponentType()voidsetBytesPerMessage(int bytesPerMessage)voidsetShouldTruncate(boolean shouldTruncate)Methods inherited from class org.springframework.integration.endpoint.AbstractMessageSource
buildMessage, destroy, getBeanName, getComponentName, getManagedName, getManagedType, getOverrides, isLoggingEnabled, receive, registerMetricsCaptor, setBeanName, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedTypeMethods inherited from class org.springframework.integration.util.AbstractExpressionEvaluator
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, onInit, setBeanFactory, setConversionServiceMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Constructor Details
-
ByteStreamReadingMessageSource
public ByteStreamReadingMessageSource(java.io.InputStream stream) -
ByteStreamReadingMessageSource
public ByteStreamReadingMessageSource(java.io.InputStream stream, int bufferSize)
-
-
Method Details
-
setBytesPerMessage
public void setBytesPerMessage(int bytesPerMessage) -
setShouldTruncate
public void setShouldTruncate(boolean shouldTruncate) -
getComponentType
public java.lang.String getComponentType() -
doReceive
protected byte[] doReceive()- Specified by:
doReceivein classorg.springframework.integration.endpoint.AbstractMessageSource<byte[]>
-