public class ByteStreamReadingMessageSource extends AbstractMessageSource<byte[]>
InputStreamSE からバイトを受信するためのポーリング可能なソース。IntegrationManagement.ManagementOverridesEXPRESSION_PARSER, loggerMETER_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, setManagedTypeafterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, onInit, setBeanFactory, setConversionServicecloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEgetIntegrationPatternTypegetThisAspublic 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()
AbstractMessageSourcepayload ですが、戻り値はペイロードが T 型の Message インスタンスでもかまいません。追加のヘッダーの作成に使用される AbstractIntegrationMessageBuilder にすることもできます。AbstractMessageSource<byte[]> の doReceive