コンストラクターの詳細

• DirectReplyToMessageListenerContainer

  public DirectReplyToMessageListenerContainer​(ConnectionFactory connectionFactory)

メソッドの詳細

• setConsumersPerQueue

  public final void setConsumersPerQueue​(int consumersPerQueue)

  クラスからコピーされた説明: DirectMessageListenerContainer
  各キューは独自のコンシューマーで実行されます。このプロパティを設定して、キューごとに複数のコンシューマーを作成します。コンテナーがすでに実行されている場合、キューごとのコンシューマーの数は必要に応じて増減されます。

  オーバーライド:

  クラス DirectMessageListenerContainer の setConsumersPerQueue 

  パラメーター:

  consumersPerQueue - キューごとのコンシューマー。

• setMonitorInterval

  public final void setMonitorInterval​(long monitorInterval)

  クラスからコピーされた説明: DirectMessageListenerContainer
  失敗したコンシューマーとアイドル状態のコンテナーをチェックするタスクを実行する頻度を設定します。

  オーバーライド:

  クラス DirectMessageListenerContainer の setMonitorInterval 

  パラメーター:

  monitorInterval - 間隔 ; デフォルトは 10000 ですが、idleEventInterval/2 (構成されている場合) または failedDeclarationRetryInterval の最小値に調整されます。

• setQueueNames

  public final void setQueueNames​(StringSE... queueName)

  クラスからコピーされた説明: AbstractMessageListenerContainer
  メッセージを受信するキューの名前を設定します。

  次で指定:

  インターフェース MessageListenerContainer の setQueueNames 

  オーバーライド:

  クラス DirectMessageListenerContainer の setQueueNames 

  パラメーター:

  queueName - 目的のキュー名 (null にすることはできません)

• addQueueNames

  public final void addQueueNames​(StringSE... queueNames)

  クラスからコピーされた説明: AbstractMessageListenerContainer
  このコンテナーのキューのリストにキューを追加します。

  オーバーライド:

  クラス DirectMessageListenerContainer の addQueueNames 

  パラメーター:

  queueNames - 追加するキュー。

• removeQueueNames

  public final boolean removeQueueNames​(StringSE... queueNames)

  クラスからコピーされた説明: AbstractMessageListenerContainer
  このコンテナーのキューのリストからキューを削除します。

  オーバーライド:

  クラス DirectMessageListenerContainer の removeQueueNames 

  パラメーター:

  queueNames - 削除するキュー。

  戻り値:

  ターゲット queueNames リストでの削除のブール結果。

• setMessageListener

  public void setMessageListener​(MessageListener messageListener)

  クラスからコピーされた説明: AbstractMessageListenerContainer
  MessageListener を設定してください。

  オーバーライド:

  クラス AbstractMessageListenerContainer の setMessageListener 

  パラメーター:

  messageListener - リスナー。

• doStart

  protected void doStart()

  クラスからコピーされた説明: AbstractMessageListenerContainer
  このコンテナーを開始し、すべての呼び出し側タスクに通知します。

  オーバーライド:

  クラス DirectMessageListenerContainer の doStart 

• processMonitorTask

  protected void processMonitorTask()

  クラスからコピーされた説明: DirectMessageListenerContainer
  サブクラスはこれをオーバーライドして、監視タスクの実行時に追加のアクションを実行できます。

  オーバーライド:

  クラス DirectMessageListenerContainer の processMonitorTask 

• findIdleConsumer

  protected int findIdleConsumer()

  クラスからコピーされた説明: DirectMessageListenerContainer
  下に調整するときは、キャンセル可能なコンシューマーを返します。consumerMonitor で同期中に呼び出されます。

  オーバーライド:

  クラス DirectMessageListenerContainer の findIdleConsumer 

  戻り値:

  コンシューマーインデックス、またはアイドルでない場合は -1。

• consumerRemoved

  protected void consumerRemoved​(org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer.SimpleConsumer consumer)

  クラスからコピーされた説明: DirectMessageListenerContainer
  コンシューマーが削除されるたびに呼び出されます。

  オーバーライド:

  クラス DirectMessageListenerContainer の consumerRemoved 

  パラメーター:

  consumer - コンシューマー。

• getChannelHolder

  public DirectReplyToMessageListenerContainer.ChannelHolder getChannelHolder()

  直接返信するコンシューマーに関連付けられたチャネルホルダーを取得します。不適切なリリースを防ぐためのコンシューマーエポックが含まれています。

  戻り値:

  チャンネルホルダー。

• releaseConsumerFor

  public void releaseConsumerFor​(DirectReplyToMessageListenerContainer.ChannelHolder channelHolder,
                                 boolean cancelConsumer,
                                 @Nullable
                                 StringSE message)

  再利用のためにチャネルに関連付けられたコンシューマーを解放します。クライアントが遅れて到着した返信を処理 / 破棄する準備ができていない場合は、cancelConsumer を true に設定します。

  パラメーター:

  channelHolder - チャンネルホルダー。

  cancelConsumer - コンシューマーをキャンセルする場合は true。

  message - cancelConsumer が true の場合にキャンセルイベントに含まれるメッセージ。