public abstract class AbstractFetchLimitingMessageSource<T> extends AbstractMessageSource<T> implements MessageSourceManagement
IntegrationManagement.ManagementOverridesEXPRESSION_PARSER, loggerMETER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME| コンストラクターと説明 |
|---|
AbstractFetchLimitingMessageSource() |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected ObjectSE | doReceive() サブクラスはこのメソッドを実装する必要があります。 |
protected abstract ObjectSE | doReceive(int maxFetchSizeToReceive) サブクラスはこのメソッドを実装する必要があります。 |
int | getMaxFetchSize() 最大フェッチサイズを返します。 |
void | setMaxFetchSize(int maxFetchSize) オブジェクトをフェッチする必要がある場合に、ソースがフェッチするオブジェクトの最大数を設定します。 |
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, waitSEgetIntegrationPatternTypegetThisAsgetComponentTypepublic void setMaxFetchSize(int maxFetchSize)
MessageSourceManagementMessageSourceManagement の setMaxFetchSize maxFetchSize - 最大フェッチサイズ。負の値は無制限を意味します。public int getMaxFetchSize()
MessageSourceManagementMessageSourceManagement の getMaxFetchSize MessageSourceManagement.setMaxFetchSize(int)protected ObjectSE doReceive()
AbstractMessageSourcepayload ですが、戻り値はペイロードが T 型の Message インスタンスでもかまいません。追加のヘッダーの作成に使用される AbstractIntegrationMessageBuilder にすることもできます。AbstractMessageSource<T> の doReceive protected abstract ObjectSE doReceive(int maxFetchSizeToReceive)
maxFetchSizeToReceive - フェッチが必要な場合にフェッチするメッセージの最大数。