public class ByteStreamReadingMessageSource
extends org.springframework.integration.endpoint.AbstractMessageSource<byte[]>
InputStream.| Constructor and Description |
|---|
ByteStreamReadingMessageSource(java.io.InputStream stream) |
ByteStreamReadingMessageSource(java.io.InputStream stream,
int bufferSize) |
| Modifier and Type | Method and Description |
|---|---|
protected byte[] |
doReceive() |
java.lang.String |
getComponentType() |
void |
setBytesPerMessage(int bytesPerMessage) |
void |
setShouldTruncate(boolean shouldTruncate) |
buildMessage, getComponentName, getManagedName, getManagedType, getMessageCount, getMessageCountLong, getOverrides, isCountsEnabled, isLoggingEnabled, receive, registerMetricsCaptor, reset, setBeanName, setCountsEnabled, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedTypeafterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, onInit, setBeanFactory, setConversionServicepublic ByteStreamReadingMessageSource(java.io.InputStream stream)
public ByteStreamReadingMessageSource(java.io.InputStream stream,
int bufferSize)
public void setBytesPerMessage(int bytesPerMessage)
public void setShouldTruncate(boolean shouldTruncate)
public java.lang.String getComponentType()
protected byte[] doReceive()
doReceive in class org.springframework.integration.endpoint.AbstractMessageSource<byte[]>