S - ターゲット CorrelationHandlerSpec 実装型。H - AbstractCorrelatingMessageHandler 実装型。public abstract class CorrelationHandlerSpec<S extends CorrelationHandlerSpec<S,H>,H extends AbstractCorrelatingMessageHandler> extends ConsumerEndpointSpec<S,H>
adviceChaincomponentsToRegister, endpointFactoryBean, handlerPARSER, targetloggerDEFAULT_PHASEOBJECT_TYPE_ATTRIBUTE| 修飾子 | コンストラクターと説明 |
|---|---|
protected | CorrelationHandlerSpec(H messageHandler) |
| 修飾子と型 | メソッドと説明 |
|---|---|
S | correlationExpression(StringSE correlationExpression) 指定された式の ExpressionEvaluatingCorrelationStrategy でハンドラーを構成します。 |
S | correlationStrategy(CorrelationStrategy correlationStrategy) |
S | correlationStrategy(ObjectSE target, StringSE methodName) ターゲットオブジェクトとメソッド名の MethodInvokingCorrelationStrategy でハンドラーを構成します。 |
S | discardChannel(MessageChannel discardChannel) |
S | discardChannel(StringSE discardChannelName) |
S | expireGroupsUponTimeout(boolean expireGroupsUponTimeout) タイムアウトのためにグループが完了した場合、グループを期限切れ(完全に削除)します。 |
S | forceReleaseAdvice(Advice... advice)forceComplete() 操作に適用する Advice オブジェクトのリストを構成します。 |
S | groupTimeout(java.util.function.FunctionSE<MessageGroup, LongSE> groupTimeoutFunction) メッセージグループに基づいて、グループタイムアウトを解決するために呼び出される関数でハンドラーを構成します。 |
S | groupTimeout(long groupTimeout) この定数値に評価されるグループタイムアウト式でハンドラーを構成します。 |
S | groupTimeoutExpression(StringSE groupTimeoutExpression) |
S | lockRegistry(LockRegistry lockRegistry)MessageGroup での同時操作のために、groupId に基づいて Lock を取得するために使用されます。 |
S | messageStore(MessageGroupStore messageStore) |
S | minimumTimeoutForEmptyGroups(long minimumTimeoutForEmptyGroups) |
S | popSequence(boolean popSequence) 出力メッセージに対して MessageBuilder.popSequenceDetails() を実行するかどうか。 |
S | processor(ObjectSE target) 各関数に適切にアノテーションが付けられたメソッドを持つ必要があるターゲットオブジェクトを使用して、 MethodInvokingCorrelationStrategy および MethodInvokingReleaseStrategy でハンドラーを構成します。 |
S | releaseExpression(StringSE releaseExpression) 指定された式の ExpressionEvaluatingReleaseStrategy でハンドラーを構成します。 |
S | releaseStrategy(ObjectSE target, StringSE methodName) ターゲットオブジェクトとメソッド名の MethodInvokingReleaseStrategy でハンドラーを構成します。 |
S | releaseStrategy(ReleaseStrategy releaseStrategy) |
S | sendPartialResultOnExpiry(boolean sendPartialResultOnExpiry) |
S | setExpireDuration(java.time.Duration expireDuration) スケジュールされたパージタスクを実行する頻度を Duration に構成します。 |
S | setExpireTimeout(long expireTimeout) ストア内の古いグループがパージするタイムアウトを構成します。 |
S | taskScheduler(TaskScheduler taskScheduler) ポーリングコンシューマーなどで、タスクをスケジュールするために TaskScheduler を構成します。 |
advice, async, autoStartup, customizeMonoReply, doGet, handleMessageAdvice, notPropagatedHeaders, order, phase, poller, requiresReply, role, sendTimeout, transactional, transactional, transactional, transactional, transactionalassertHandler, getComponentsToRegister, id, obtainInputChannelFromFlow, obtainInputChannelFromFlow, poller, poller_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stopafterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingletoncloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEprotected CorrelationHandlerSpec(H messageHandler)
public S messageStore(MessageGroupStore messageStore)
messageStore - メッセージグループストア。AbstractCorrelatingMessageHandler.setMessageStore(MessageGroupStore)public S sendPartialResultOnExpiry(boolean sendPartialResultOnExpiry)
sendPartialResultOnExpiry - sendPartialResultOnExpiry。AbstractCorrelatingMessageHandler.setSendPartialResultOnExpiry(boolean)public S minimumTimeoutForEmptyGroups(long minimumTimeoutForEmptyGroups)
minimumTimeoutForEmptyGroups - minimumTimeoutForEmptyGroupsAbstractCorrelatingMessageHandler.setMinimumTimeoutForEmptyGroups(long)public S groupTimeout(long groupTimeout)
groupTimeout - グループのタイムアウト(ミリ秒)。AbstractCorrelatingMessageHandler.setGroupTimeoutExpression(org.springframework.expression.Expression), ValueExpressionpublic S groupTimeoutExpression(StringSE groupTimeoutExpression)
groupTimeoutExpression - グループタイムアウト式文字列。AbstractCorrelatingMessageHandler.setGroupTimeoutExpression(org.springframework.expression.Expression)public S groupTimeout(java.util.function.FunctionSE<MessageGroup,LongSE> groupTimeoutFunction)
.groupTimeout(g -> g.size() * 2000L).
groupTimeoutFunction - グループのタイムアウトをミリ秒単位で解決するために呼び出される関数。AbstractCorrelatingMessageHandler.setGroupTimeoutExpression(org.springframework.expression.Expression)public S taskScheduler(TaskScheduler taskScheduler)
ConsumerEndpointSpecTaskScheduler を構成します。デフォルトでは、グローバル ThreadPoolTaskScheduler Bean が使用されます。この構成は、たとえば、ポーリングタスク専用のスレッドを用意する必要がある場合に役立ちます。ConsumerEndpointSpec<S extends CorrelationHandlerSpec<S, H>,H extends AbstractCorrelatingMessageHandler> の taskScheduler taskScheduler - タスクスケジューラ。IntegrationObjectSupport.setTaskScheduler(TaskScheduler)public S discardChannel(MessageChannel discardChannel)
discardChannel - 廃棄チャネル。AbstractCorrelatingMessageHandler.setDiscardChannel(MessageChannel)public S discardChannel(StringSE discardChannelName)
discardChannelName - 廃棄チャネル。AbstractCorrelatingMessageHandler.setDiscardChannelName(String)public S processor(ObjectSE target)
MethodInvokingCorrelationStrategy および MethodInvokingReleaseStrategy でハンドラーを構成します。target - ターゲットオブジェクト AbstractCorrelatingMessageHandler.setCorrelationStrategy(CorrelationStrategy), AbstractCorrelatingMessageHandler.setReleaseStrategy(ReleaseStrategy)public S correlationExpression(StringSE correlationExpression)
ExpressionEvaluatingCorrelationStrategy でハンドラーを構成します。correlationExpression - 相関式。AbstractCorrelatingMessageHandler.setCorrelationStrategy(CorrelationStrategy)public S correlationStrategy(ObjectSE target, StringSE methodName)
MethodInvokingCorrelationStrategy でハンドラーを構成します。target - ターゲットオブジェクト。methodName - メソッド名。AbstractCorrelatingMessageHandler.setCorrelationStrategy(CorrelationStrategy)public S correlationStrategy(CorrelationStrategy correlationStrategy)
correlationStrategy - 相関戦略。AbstractCorrelatingMessageHandler.setCorrelationStrategy(CorrelationStrategy)public S releaseExpression(StringSE releaseExpression)
ExpressionEvaluatingReleaseStrategy でハンドラーを構成します。releaseExpression - 相関式。AbstractCorrelatingMessageHandler.setReleaseStrategy(ReleaseStrategy)public S releaseStrategy(ObjectSE target, StringSE methodName)
MethodInvokingReleaseStrategy でハンドラーを構成します。target - ターゲットオブジェクト。methodName - メソッド名。AbstractCorrelatingMessageHandler.setReleaseStrategy(ReleaseStrategy)public S releaseStrategy(ReleaseStrategy releaseStrategy)
releaseStrategy - リリース戦略。AbstractCorrelatingMessageHandler.setReleaseStrategy(ReleaseStrategy)public S expireGroupsUponTimeout(boolean expireGroupsUponTimeout)
true とリシーケンサーの false。expireGroupsUponTimeout - 設定する expireGroupsUponTimeoutAbstractCorrelatingMessageHandler.setExpireGroupsUponTimeout(boolean)public S forceReleaseAdvice(Advice... advice)
forceComplete() 操作に適用する Advice オブジェクトのリストを構成します。advice - アドバイスチェーン。public S lockRegistry(LockRegistry lockRegistry)
MessageGroup での同時操作のために groupId に基づいて Lock を取得するために使用されます。デフォルトでは、内部 DefaultLockRegistry が使用されます。RedisLockRegistry などの分散 LockRegistry を使用すると、アグリゲーターの 1 つのインスタンスのみがグループで同時に動作することが保証されます。lockRegistry - 使用する LockRegistry。public S popSequence(boolean popSequence)
MessageBuilder.popSequenceDetails() を実行するかどうか。popSequence - 使用するブールフラグ。AbstractCorrelatingMessageHandler.setPopSequence(boolean)public S setExpireTimeout(long expireTimeout)
expireTimeout - 使用するミリ秒単位のタイムアウト。AbstractCorrelatingMessageHandler.setExpireTimeout(long)public S setExpireDuration(java.time.Duration expireDuration)
Duration に構成します。expireDuration - スケジュールされたパージタスクの期間。AbstractCorrelatingMessageHandler.setExpireDuration(Duration)