クラス CorrelationHandlerSpec<S extends CorrelationHandlerSpec<S,H>,H extends AbstractCorrelatingMessageHandler>

メソッドの詳細

• messageStore

  public S messageStore(MessageGroupStore messageStore)

  パラメーター:

  messageStore - メッセージグループストア。

  戻り値:

  ハンドラーの仕様。

  関連事項:

  • AbstractCorrelatingMessageHandler.setMessageStore(MessageGroupStore)

• sendPartialResultOnExpiry

  public S sendPartialResultOnExpiry(boolean sendPartialResultOnExpiry)

  パラメーター:

  sendPartialResultOnExpiry - sendPartialResultOnExpiry。

  戻り値:

  ハンドラーの仕様。

  関連事項:

  • AbstractCorrelatingMessageHandler.setSendPartialResultOnExpiry(boolean)

• minimumTimeoutForEmptyGroups

  public S minimumTimeoutForEmptyGroups(long minimumTimeoutForEmptyGroups)

  パラメーター:

  minimumTimeoutForEmptyGroups - minimumTimeoutForEmptyGroups

  戻り値:

  ハンドラーの仕様。

  関連事項:

  • AbstractCorrelatingMessageHandler.setMinimumTimeoutForEmptyGroups(long)

• groupTimeout

  public S groupTimeout(long groupTimeout)

  この定数値に評価されるグループタイムアウト式でハンドラーを構成します。

  パラメーター:

  groupTimeout - グループのタイムアウト（ミリ秒）。

  戻り値:

  ハンドラーの仕様。

  関連事項:

  • AbstractCorrelatingMessageHandler.setGroupTimeoutExpression(org.springframework.expression.Expression)
  • ValueExpression

• groupTimeoutExpression

  public S groupTimeoutExpression(StringSE groupTimeoutExpression)

  SpEL 式を指定して、スケジュールされた有効期限のグループタイムアウトを評価します。DateSE、LongSE、StringSE を long として返す必要があります。

  パラメーター:

  groupTimeoutExpression - グループタイムアウト式文字列。

  戻り値:

  ハンドラーの仕様。

  関連事項:

  • AbstractCorrelatingMessageHandler.setGroupTimeoutExpression(org.springframework.expression.Expression)

• groupTimeout

  public S groupTimeout(FunctionSE<MessageGroup,?> groupTimeoutFunction)

  メッセージグループに基づいて、グループタイムアウトを解決するために呼び出される関数でハンドラーを構成します。通常、JDK8 ラムダで使用されます。

  .groupTimeout(g -> g.size() * 2000L)。DateSE、LongSE、StringSE を長く返す必要があります。

  パラメーター:

  groupTimeoutFunction - グループのタイムアウトをミリ秒単位で解決するために呼び出される関数。

  戻り値:

  ハンドラーの仕様。

  関連事項:

  • AbstractCorrelatingMessageHandler.setGroupTimeoutExpression(org.springframework.expression.Expression)

• taskScheduler

  public S taskScheduler(TaskScheduler taskScheduler)

  クラスからコピーされた説明: ConsumerEndpointSpec

  たとえば、ポーリングコンシューマーでタスクをスケジュールするために TaskScheduler を構成します。デフォルトでは、グローバル ThreadPoolTaskScheduler Bean が使用されます。この構成は、たとえばポーリングタスクに特定のスレッドを専用にする必要がある場合に役立ちます。

  オーバーライド:

  クラス ConsumerEndpointSpec<S extends CorrelationHandlerSpec<S,H>,H extends AbstractCorrelatingMessageHandler> の taskScheduler 

  パラメーター:

  taskScheduler - タスクスケジューラ。

  戻り値:

  ハンドラーの仕様。

  関連事項:

  • IntegrationObjectSupport.setTaskScheduler(TaskScheduler)

• discardChannel

  public S discardChannel(MessageChannel discardChannel)

  パラメーター:

  discardChannel - 廃棄チャネル。

  戻り値:

  ハンドラーの仕様。

  関連事項:

  • AbstractCorrelatingMessageHandler.setDiscardChannel(MessageChannel)

• discardChannel

  public S discardChannel(StringSE discardChannelName)

  パラメーター:

  discardChannelName - 廃棄チャネル。

  戻り値:

  ハンドラーの仕様。

  関連事項:

  • AbstractCorrelatingMessageHandler.setDiscardChannelName(String)

• processor

  public S processor(ObjectSE target)

  各関数に適切にアノテーションが付けられたメソッドを持つ必要があるターゲットオブジェクトを使用して、MethodInvokingCorrelationStrategy および MethodInvokingReleaseStrategy でハンドラーを構成します。

  パラメーター:

  target - ターゲットオブジェクト

  戻り値:

  ハンドラーの仕様。

  関連事項:

  • AbstractCorrelatingMessageHandler.setCorrelationStrategy(CorrelationStrategy)
  • AbstractCorrelatingMessageHandler.setReleaseStrategy(ReleaseStrategy)

• correlationExpression

  public S correlationExpression(StringSE correlationExpression)

  指定された式の ExpressionEvaluatingCorrelationStrategy でハンドラーを構成します。

  パラメーター:

  correlationExpression - 相関式。

  戻り値:

  ハンドラーの仕様。

  関連事項:

  • AbstractCorrelatingMessageHandler.setCorrelationStrategy(CorrelationStrategy)

• correlationStrategy

  public S correlationStrategy(ObjectSE target, StringSE methodName)

  ターゲットオブジェクトとメソッド名の MethodInvokingCorrelationStrategy でハンドラーを構成します。

  パラメーター:

  target - ターゲットオブジェクト。

  methodName - メソッド名。

  戻り値:

  ハンドラーの仕様。

  関連事項:

  • AbstractCorrelatingMessageHandler.setCorrelationStrategy(CorrelationStrategy)

• correlationStrategy

  public S correlationStrategy(CorrelationStrategy correlationStrategy)

  パラメーター:

  correlationStrategy - 相関戦略。

  戻り値:

  ハンドラーの仕様。

  関連事項:

  • AbstractCorrelatingMessageHandler.setCorrelationStrategy(CorrelationStrategy)

• releaseExpression

  public S releaseExpression(StringSE releaseExpression)

  指定された式の ExpressionEvaluatingReleaseStrategy でハンドラーを構成します。

  パラメーター:

  releaseExpression - 相関式。

  戻り値:

  ハンドラーの仕様。

  関連事項:

  • AbstractCorrelatingMessageHandler.setReleaseStrategy(ReleaseStrategy)

• releaseStrategy

  public S releaseStrategy(ObjectSE target, StringSE methodName)

  ターゲットオブジェクトとメソッド名の MethodInvokingReleaseStrategy でハンドラーを構成します。

  パラメーター:

  target - ターゲットオブジェクト。

  methodName - メソッド名。

  戻り値:

  ハンドラーの仕様。

  関連事項:

  • AbstractCorrelatingMessageHandler.setReleaseStrategy(ReleaseStrategy)

• releaseStrategy

  public S releaseStrategy(ReleaseStrategy releaseStrategy)

  パラメーター:

  releaseStrategy - リリース戦略。

  戻り値:

  ハンドラーの仕様。

  関連事項:

  • AbstractCorrelatingMessageHandler.setReleaseStrategy(ReleaseStrategy)

• expireGroupsUponTimeout

  public S expireGroupsUponTimeout(boolean expireGroupsUponTimeout)

  タイムアウトのためにグループが完了した場合、グループを期限切れにします（完全に削除します）。アグリゲーターのデフォルトの true とリシーケンサーの false。

  パラメーター:

  expireGroupsUponTimeout - 設定する expireGroupsUponTimeout

  戻り値:

  ハンドラーの仕様。

  関連事項:

  • AbstractCorrelatingMessageHandler.setExpireGroupsUponTimeout(boolean)

• forceReleaseAdvice

  public S forceReleaseAdvice(Advice... advice)

  forceComplete() 操作に適用する Advice オブジェクトのリストを構成します。

  パラメーター:

  advice - アドバイスチェーン。

  戻り値:

  エンドポイント仕様。

• lockRegistry

  public S lockRegistry(LockRegistry lockRegistry)

  MessageGroup での同時操作のために groupId に基づいて Lock を取得するために使用されます。デフォルトでは、内部 DefaultLockRegistry が使用されます。RedisLockRegistry などの分散 LockRegistry を使用すると、アグリゲーターの 1 つのインスタンスのみがグループで同時に動作することが保証されます。

  パラメーター:

  lockRegistry - 使用する LockRegistry。

  戻り値:

  エンドポイント仕様。

• popSequence

  public S popSequence(boolean popSequence)

  出力メッセージに対して BaseMessageBuilder.popSequenceDetails() を実行するかどうか。

  パラメーター:

  popSequence - 使用するブールフラグ。

  戻り値:

  エンドポイント仕様。

  導入:

  5.1

  関連事項:

  • AbstractCorrelatingMessageHandler.setPopSequence(boolean)

• expireTimeout

  public S expireTimeout(long expireTimeout)

  ストア内の古いグループがパージするタイムアウトを構成します。

  パラメーター:

  expireTimeout - 使用するミリ秒単位のタイムアウト。

  戻り値:

  エンドポイント仕様。

  導入:

  5.5

  関連事項:

  • AbstractCorrelatingMessageHandler.setExpireTimeout(long)

• expireDuration

  public S expireDuration(DurationSE expireDuration)

  スケジュールされたパージタスクを実行する頻度を DurationSE に設定します。

  パラメーター:

  expireDuration - スケジュールされたパージタスクの期間。

  戻り値:

  エンドポイント仕様。

  導入:

  5.5

  関連事項:

  • AbstractCorrelatingMessageHandler.setExpireDuration(Duration)

• releaseLockBeforeSend

  public S releaseLockBeforeSend(boolean releaseLockBeforeSend)

  true に設定すると、出力を送信する前にメッセージグループロックが解除されます。これが必要になる理由の詳細については、リファレンスマニュアルの「アグリゲーター」セクションの「デッドロックの回避」を参照してください。

  パラメーター:

  releaseLockBeforeSend - ロックを解除するには true。

  戻り値:

  エンドポイント仕様。

  導入:

  5.5

  関連事項:

  • AbstractCorrelatingMessageHandler.setReleaseLockBeforeSend(boolean)

• groupConditionSupplier

  public S groupConditionSupplier(BiFunctionSE<Message<?>,StringSE,StringSE> conditionSupplier)

  グループに追加されるメッセージからグループ条件を提供するように BiFunctionSE を構成します。関数からの null の結果は、以前に設定された条件をリセットします。

  パラメーター:

  conditionSupplier - グループに追加するメッセージからグループ条件を提供する機能。

  戻り値:

  エンドポイント仕様。

  導入:

  5.5