コンストラクターの詳細

• RotatingServerAdvice

  public RotatingServerAdvice(DelegatingSessionFactory<?> factory,
                              ListSE<RotationPolicy.KeyDirectory> keyDirectories)

  メッセージが受信されない場合、次のサーバー / ディレクトリにローテーションするインスタンスを作成します。

  パラメーター:

  factory - DelegatingSessionFactory

  keyDirectories - RotationPolicy.KeyDirectory のリスト。

• RotatingServerAdvice

  public RotatingServerAdvice(DelegatingSessionFactory<?> factory,
                              ListSE<RotationPolicy.KeyDirectory> keyDirectories,
                              boolean fair)

  公平な引数に応じて、次のサーバー / ディレクトリにローテーションするインスタンスを作成します。

  パラメーター:

  factory - DelegatingSessionFactory

  keyDirectories - RotationPolicy.KeyDirectory のリスト。

  fair - ポーリングごとにローテーションする場合は true、メッセージを受信しない場合にローテーションする場合は false。

• RotatingServerAdvice

  public RotatingServerAdvice(RotationPolicy rotationPolicy)

  指定された RotationPolicy に従って回転するインスタンスを構築します。

  パラメーター:

  rotationPolicy - ポリシー。

メソッドの詳細

• beforeReceive

  public boolean beforeReceive(MessageSource<?> source)

  インターフェースからコピーされた説明: MessageSourceMutator
  サブクラスは、このポーリングを続行するかどうかを決定できます。

  次で指定:

  インターフェース MessageSourceMutator の beforeReceive 

  パラメーター:

  source - メッセージソース。

  戻り値:

  続行するには true（デフォルト）。

• afterReceive

  @Nullable
  public Message<?> afterReceive(@Nullable
                                           Message<?> result,
                                           MessageSource<?> source)

  インターフェースからコピーされた説明: MessageSourceMutator
  サブクラスは、ポーリングの結果に基づいてアクションを実行できます。たとえば trigger を調整します。メッセージは新しいメッセージに置き換えることもできます。

  次で指定:

  インターフェース MessageSourceMutator の afterReceive 

  パラメーター:

  result - 受信したメッセージ。

  source - メッセージソース。

  戻り値:

  結果の処理を続行するメッセージ。ポーリングが返したものをすべて破棄する場合は null