クラス SimpleMessageListenerContainer

メソッドの詳細

• setConnectLazily

  public void setConnectLazily(boolean connectLazily)

  遅延接続するかどうか、つまり、このコンテナーの開始段階で、JMS 接続および対応するセッションと MessageConsumers をできるだけ遅く確立するかどうかを指定します。

  デフォルトは「false」: 早い段階、つまり Bean の初期化段階で接続します。ターゲットブローカーがまだ起動していない可能性が高く、接続を試行しないことを希望する場合は、遅延接続に切り替えるには、このフラグを "true" に設定します。

  関連事項:

  • AbstractJmsListeningContainer.start()
  • AbstractJmsListeningContainer.initialize()

• setRecoverOnException

  public void setRecoverOnException(boolean recoverOnException)

  JMSException が報告されるたびに、共有 JMS 接続と関連するセッションおよび MessageConsumers を明示的に回復するかどうかを指定します。

  デフォルトは「true」: 接続がリスナーに例外を伝播するたびに、共有接続をリフレッシュし、コンシューマーを再初期化します。既存の接続とコンシューマーハンドルを保持したまま、プロバイダー内の自動回復に依存するには、このフラグを "false" に設定します。

  導入:

  5.1.8

  関連事項:

  • onException(JMSException)
  • Connection.setExceptionListener(ExceptionListener)

• setConcurrency

  public void setConcurrency(StringSE concurrency)

  同時実行制限は、"5-10" などの「下限 - 上限」文字列、または "10" などの単純な上限文字列で指定します。

  このリスナーコンテナーは、スケーリングできないため、常に最大数のコンシューマー setConcurrentConsumers(int) を保持します。

  このプロパティは、DefaultMessageListenerContainer との構成互換性のために主にサポートされています。このローカルリスナーコンテナーには、通常、代わりに setConcurrentConsumers(int) を使用します。

  次で指定:

  クラス AbstractMessageListenerContainer の setConcurrency 

• setConcurrentConsumers

  public void setConcurrentConsumers(int concurrentConsumers)

  作成する同時コンシューマーの数を指定します。デフォルトは 1 です。

  同時コンシューマーの数を増やすことは、キューから入ってくるメッセージの消費を拡大するために推奨されます。ただし、複数のコンシューマーが登録されると、順序付けの保証は失われます。一般に、少量のキューの場合は 1 つのコンシューマーに固執します。

  トピックの同時コンシューマーの数を上げないでください。これにより、同じメッセージが同時に消費されることになり、望ましくありません。

• setTaskExecutor

  public void setTaskExecutor(ExecutorSE taskExecutor)

  プロバイダーがメッセージを受信した後、リスナーの実行に使用する Spring TaskExecutor を設定します。

  デフォルトは none です。つまり、JMS プロバイダーの独自の受信スレッドで実行され、リスナーの実行中にプロバイダーの受信エンドポイントをブロックします。

  通常、既存のスレッドプールと統合する JMS プロバイダーをブロックするのではなく、別のスレッドでリスナーを実行するために TaskExecutor を指定します。これにより、メッセージを同時に処理している間（受信から切り離されている！ ）、同時に使用するコンシューマーの数を少なくすることができます。(1)。

  注: リスナーの実行に TaskExecutor を指定すると、確認応答のセマンティクスに影響します。その場合、メッセージはリスナーの実行前に常に確認され、基礎となるセッションは次のメッセージを受信するためにすぐに再利用されます。これをトランザクションセッションまたはクライアント確認応答と組み合わせて使用すると、不特定の結果につながります。

  注意: TaskExecutor を介した同時リスナー実行は、同じ基盤となる Session で受信されたメッセージの同時処理につながります。少なくとも後者が特定の Session で実際の処理を実行する場合は、この設定を SessionAwareMessageListener で使用することは推奨されません。一般的には、標準的な MessageListener で問題なく動作します。

  関連事項:

  • setConcurrentConsumers(int)
  • SimpleAsyncTaskExecutor

• validateConfiguration

  protected void validateConfiguration()

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

  このコンテナーの構成を検証します。

  デフォルトの実装は空です。サブクラスでオーバーライドされます。

  オーバーライド:

  クラス AbstractMessageListenerContainer の validateConfiguration 

• sharedConnectionEnabled

  protected final boolean sharedConnectionEnabled()

  常に共有 JMS 接続を使用します。

  次で指定:

  クラス AbstractJmsListeningContainer の sharedConnectionEnabled 

  関連事項:

  • AbstractJmsListeningContainer.getSharedConnection()

• doInitialize

  protected void doInitialize() throws jakarta.jms.JMSException

  JMS セッションと関連する MessageConsumer の形式で、指定された数の同時コンシューマーを作成します。

  次で指定:

  クラス AbstractJmsListeningContainer の doInitialize 

  例外:

  jakarta.jms.JMSException - 登録に失敗した場合

  関連事項:

  • createListenerConsumer(Session)

• doStart

  protected void doStart() throws jakarta.jms.JMSException

  まだ初期化されていない場合、このコンテナーの JMS メッセージコンシューマーを再初期化します。

  オーバーライド:

  クラス AbstractJmsListeningContainer の doStart 

  例外:

  jakarta.jms.JMSException - JMS API メソッドによってスローされた場合

  関連事項:

  • AbstractJmsListeningContainer.startSharedConnection()

• prepareSharedConnection

  protected void prepareSharedConnection(jakarta.jms.Connection connection) throws jakarta.jms.JMSException

  このリスナーコンテナーを共有接続の JMS ExceptionListener として登録します。

  オーバーライド:

  クラス AbstractJmsListeningContainer の prepareSharedConnection 

  パラメーター:

  connection - 準備する接続

  例外:

  jakarta.jms.JMSException - 準備作業が失敗した場合

  関連事項:

  • AbstractJmsListeningContainer.getClientId()

• onException

  public void onException(jakarta.jms.JMSException ex)

  接続に失敗した場合に JMS プロバイダーによって呼び出される JMS ExceptionListener 実装。必要に応じて、このリスナーコンテナーの共有接続とそのセッションおよびコンシューマーを再初期化します。

  次で指定:

  インターフェース jakarta.jms.ExceptionListener の onException 

  パラメーター:

  ex - 報告された接続例外

  関連事項:

  • setRecoverOnException(boolean)
  • AbstractJmsListeningContainer.refreshSharedConnection()
  • initializeConsumers()

• initializeConsumers

  protected void initializeConsumers() throws jakarta.jms.JMSException

  このコンテナーの JMS セッションと MessageConsumers を初期化します。

  例外:

  jakarta.jms.JMSException - セットアップが失敗した場合

• createListenerConsumer

  protected jakarta.jms.MessageConsumer createListenerConsumer(jakarta.jms.Session session) throws jakarta.jms.JMSException

  指定された JMS セッションの MessageConsumer を作成し、指定されたリスナーの MessageListener を登録します。

  パラメーター:

  session - 作業する JMS セッション

  戻り値:

  MessageConsumer

  例外:

  jakarta.jms.JMSException - JMS メソッドによってスローされた場合

  関連事項:

  • AbstractMessageListenerContainer.executeListener(Session, Message)

• processMessage

  protected void processMessage(jakarta.jms.Message message, jakarta.jms.Session session)

  プロバイダーから受信したメッセージを処理します。

  リスナーを実行し、現在の JMS セッションをスレッドバインドリソースとして公開します ( "exposeListenerSession" が "true" の場合)。

  パラメーター:

  message - 受信した JMS メッセージ

  session - 操作する JMS セッション

  関連事項:

  • AbstractMessageListenerContainer.executeListener(Session, Message)
  • AbstractMessageListenerContainer.setExposeListenerSession(boolean)

• doShutdown

  protected void doShutdown() throws jakarta.jms.JMSException

  登録済みの JMS セッションと関連する MessageConsumers を破棄します。

  次で指定:

  クラス AbstractJmsListeningContainer の doShutdown 

  例外:

  jakarta.jms.JMSException - シャットダウンに失敗した場合

  関連事項:

  • AbstractJmsListeningContainer.shutdown()