public class ByteStreamReadingMessageSource extends AbstractMessageSource<byte[]>
InputStream
SE からバイトを受信するためのポーリング可能なソース。IntegrationManagement.ManagementOverrides
EXPRESSION_PARSER, logger
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターと説明 |
---|
ByteStreamReadingMessageSource(InputStreamSE stream) |
ByteStreamReadingMessageSource(InputStreamSE stream, int bufferSize) |
修飾子と型 | メソッドと説明 |
---|---|
protected byte[] | doReceive() サブクラスはこのメソッドを実装する必要があります。 |
StringSE | getComponentType() |
void | setBytesPerMessage(int bytesPerMessage) |
void | setShouldTruncate(boolean shouldTruncate) |
buildMessage, destroy, getBeanName, getComponentName, getManagedName, getManagedType, getOverrides, isLoggingEnabled, receive, registerMetricsCaptor, setBeanName, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedType
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, onInit, setBeanFactory, setConversionService
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
getIntegrationPatternType
getThisAs
public ByteStreamReadingMessageSource(InputStreamSE stream)
public ByteStreamReadingMessageSource(InputStreamSE stream, int bufferSize)
public void setBytesPerMessage(int bytesPerMessage)
public void setShouldTruncate(boolean shouldTruncate)
public StringSE getComponentType()
protected byte[] doReceive()
AbstractMessageSource
payload
ですが、戻り値はペイロードが T 型の Message
インスタンスでもかまいません。追加のヘッダーの作成に使用される AbstractIntegrationMessageBuilder
にすることもできます。AbstractMessageSource<byte[]>
の doReceive