クラス DirectReplyToMessageListenerContainer

メソッドの詳細

• 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

  下方調整する場合は、キャンセル可能なコンシューマーを返します。AbstractMessageListenerContainer.consumersLock でロックされているときに呼び出されます。

  オーバーライド:

  クラス DirectMessageListenerContainer の findIdleConsumer 

  戻り値:

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

• consumerRemoved

  protected void consumerRemoved(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 の場合にキャンセルイベントに含まれるメッセージ。