パッケージ org.springframework.integration.annotation

アノテーション型 Aggregator

@TargetSE({METHODSE,ANNOTATION_TYPESE})
@RetentionSE(RUNTIMESE)
@DocumentedSE
public @interface Aggregator
メソッドがメッセージを集約できることを示します。

@Aggregator アノテーションが付けられたメソッドは、メッセージまたはメッセージペイロードのコレクションを受け入れる場合があり、メッセージペイロードとして使用される単一のメッセージまたは単一のオブジェクトを返す必要があります。

作成者:
Marius Bogoevici, Oleg Zhurakousky, Artem Bilan

  • 要素の詳細

    • inputChannel

      StringSE inputChannel
      戻り値:
      集約されるメッセージを受信するためのチャネル名
      デフォルト:
      ""

    • outputChannel

      StringSE outputChannel
      戻り値:
      集約された結果メッセージを送信するためのチャネル名
      デフォルト:
      ""

    • discardChannel

      StringSE discardChannel
      戻り値:
      破棄されたメッセージを送信するためのチャネル名 (タイムアウトによる)
      デフォルト:
      ""

    • sendTimeout

      StringSE sendTimeout
      応答 Message を outputChannel() に送信するときに待機する最大時間をミリ秒単位で指定します。デフォルトは -1 (無期限にブロック) です。出力チャネルに何らかの「送信」制限がある場合のみ適用されます (例: 固定の「容量」を持つ QueueChannel が現在いっぱいの場合)。この場合、MessageDeliveryException がスローされます。AbstractSubscribableChannel 実装の場合、"sendTimeout" は無視されます。「プロパティプレースホルダー」として指定できます (例: ${spring.integration.sendTimeout})。
      戻り値:
      結果を応答ターゲットに送信するためのタイムアウト (ミリ秒単位)
      デフォルト:
      ""

    • sendPartialResultsOnExpiry

      StringSE sendPartialResultsOnExpiry
      期限切れになったメッセージを集約して、メッセージヘッダーから outputChannel() または replyChannel のどちらに送信するかを指定します。メッセージは、含まれている MessageGroup が期限切れになると期限切れになります。MessageGroups を期限切れにする方法の 1 つは、MessageGroupStoreReaper を構成することです。ただし、MessageGroups は、MessageGroupStore.expireMessageGroup(groupId) を呼び出すだけで期限切れにすることもできます。これは、ControlBus 操作を介して、または MessageGroupStore インスタンスへの参照がある場合はそのメソッドを呼び出すことによって実現できます。デフォルトは false です。*「プロパティプレースホルダー」として指定できます。例: ${spring.integration.sendPartialResultsOnExpiry}。
      戻り値:
      メッセージグループの満了時に不完全な集約を送信するかどうかを示します
      デフォルト:
      ""

    • autoStartup

      StringSE autoStartup
      SmartLifecycle autoStartup オプション。「プロパティプレースホルダー」として指定できます。例: ${foo.autoStartup}。デフォルトは true です。
      戻り値:
      自動起動 boolean フラグ。
      デフォルト:
      ""

    • phase

      StringSE phase
      SmartLifecycle phase オプションを指定します。デフォルトは、PollingConsumer の場合は Integer.MAX_VALUE / 2、EventDrivenConsumer の場合は Integer.MIN_VALUE です。「プロパティプレースホルダー」として指定できます。例: ${foo.phase}。
      戻り値:
      SmartLifecycle フェーズ。
      デフォルト:
      ""

    • poller

      Poller[] poller
      戻り値:
      ポーリングされたエンドポイントの Poller オプション（PollerMetadata）。この属性は、空のデフォルト（ポーラーなし）を許可するための array です。reactive() と相互に排他的です。
      デフォルト:
      {}

    • reactive

      Reactive reactive
      戻り値:
      コンシューマーエンドポイントの Reactive マーカー。poller() と相互に排他的です。
      導入:
      5.5
      デフォルト:
      @org.springframework.integration.annotation.Reactive("\n\t\t\n\t\t\n\ue000\ue001\ue002\n\t\t\t\t\n")