パッケージ org.springframework.jms.listener

クラス AbstractMessageListenerContainer

java.lang.ObjectSE
org.springframework.jms.support.JmsAccessor
org.springframework.jms.support.destination.JmsDestinationAccessor
org.springframework.jms.listener.AbstractJmsListeningContainer
org.springframework.jms.listener.AbstractMessageListenerContainer
実装されたすべてのインターフェース:
Aware、BeanNameAware、DisposableBean、InitializingBean、Lifecycle、Phased、SmartLifecycle、MessageListenerContainer
既知の直属サブクラス
AbstractPollingMessageListenerContainer, SimpleMessageListenerContainer
public abstract class AbstractMessageListenerContainer extends AbstractJmsListeningContainer implements MessageListenerContainer
Spring メッセージリスナーコンテナー実装の抽象基本クラス。実際のメッセージ処理のために、標準の JMS MessageListenerEE または Spring の SessionAwareMessageListener をホストできます。

通常、すべてのリスナーが登録されることになっている単一の JMS ConnectionEE を保持します。これは、リスナーセッションを管理する標準の JMS 方法です。あるいは、Jakarta EE スタイルの XA 対応 JMS メッセージングのために、リスナーごとの新しい接続で使用することもできます。実際の登録プロセスは具象サブクラス次第です。

注 : このメッセージリスナーコンテナーのデフォルトの動作では、メッセージリスナーによってスローされた例外が JMS プロバイダーに伝播されることはありません。代わりに、そのような例外は WARN レベルでログに記録されます。これは、付随の JMS プロバイダーの観点からは、そのようなリスナーが失敗することは決してないことを意味します。ただし、エラー処理が必要な場合は、ErrorHandler 戦略の実装を setErrorHandler(ErrorHandler) メソッドに提供できます。JMSException は、ExceptionListenerEE が指定されている場合、それに加えて (ただしその後に) ErrorHandler に渡されることに注意してください。

リスナーコンテナーは、次のメッセージ確認オプションを提供します。

  • "sessionAcknowledgeMode" セット "AUTO_ACKNOWLEDGE" （デフォルト）: DefaultMessageListenerContainer ために、いずれかの他のリスナーの実行の中断の場合には、例外の場合にない再送なし再配信して、リスナーの実行前に自動メッセージの肯定応答を意味する: このモードは、コンテナーに依存します。SimpleMessageListenerContainer の場合、これはリスナー実行後の自動メッセージ確認応答を意味し、ユーザー例外がスローされた場合は再配信されませんが、JVM がリスナー実行中に停止した場合は再配信される可能性があります。コンテナーバリアントでの再配信を一貫して調整するには、"CLIENT_ACKNOWLEDGE" モードを検討するか、できれば "sessionTransacted" を "true" に設定することを検討してください。
  • "sessionAcknowledgeMode" を "DUPS_OK_ACKNOWLEDGE" に設定: リスナー実行中（DefaultMessageListenerContainer）またはその直後（SimpleMessageListenerContainer）の遅延メッセージ確認。ユーザー例外がスローされた場合の再配信はありませんが、JVM がリスナーの実行中に停止した場合の再配信の可能性があります。コンテナーバリアントでの再配信を一貫して調整するには、"CLIENT_ACKNOWLEDGE" モードを検討するか、できれば "sessionTransacted" を "true" に設定することを検討してください。
  • "sessionAcknowledgeMode" を "CLIENT_ACKNOWLEDGE" に設定: リスナーが正常に実行された後の自動メッセージ確認。ユーザー例外がスローされた場合、および他のリスナーの実行が中断された場合（JVM の停止など）の場合のベストエフォートの再配信。
  • "sessionTransacted" を "true" に設定: リスナーが正常に実行された後のトランザクションの確認。ユーザー例外がスローされた場合、および他のリスナー実行が中断した場合（JVM が停止した場合など）の場合は、 再配信が保証されます。

重複メッセージ処理の問題には 2 つの解決策があります。

  • ビジネスエンティティの存在チェックまたはプロトコルテーブルチェックの形式で、 重複メッセージ検出をリスナーに追加します。これは通常、受信メッセージに JMSRedelivered フラグが設定されている場合にのみ実行する必要があります（それ以外の場合は、直接処理します）。"sessionTransacted" が "true" に設定されている場合、重複するメッセージは、JVM が可能な限り不幸なポイントで停止した場合（つまり、ビジネスロジックが実行された後、JMS パーツがコミットされる前）にのみ表示されるため、重複メッセージの検出はコーナーケースをカバーするためだけにあります。
  • または 、XA トランザクションで処理全体をラップし、JMS メッセージの受信と、メッセージリスナーでのビジネスロジックの実行（データベース操作など）をカバーします。これは、外部の "transactionManager"（通常、対応する XA 対応の JMS ConnectionFactoryEE が "connectionFactory" として渡される JtaTransactionManager）を指定することによって、DefaultMessageListenerContainer によってのみサポートされます。
XA トランザクション調整は実行時のオーバーヘッドを大幅に追加するため、どうしても必要な場合を除いて、回避することも可能です。

推奨:

  • 一般的な推奨事項は、"sessionTransacted" を "true" に設定することです。通常は、Spring の標準トランザクション機能を通じて、リスナー実装によってトリガーされるローカルデータベーストランザクションと組み合わせて使用します。これは、Tomcat またはスタンドアロン環境でうまく機能し、カスタムの重複メッセージ検出と組み合わせられることがよくあります（同じメッセージを 2 回処理することが許容できない場合）。
  • または、完全に XA 対応の JMS プロバイダーの "transactionManager" として JtaTransactionManager を指定します。通常、Jakarta EE サーバーで実行する場合だけでなく、JTA トランザクションマネージャーが存在する他の環境でも実行できます。これにより、追加のランタイム処理オーバーヘッドを犠牲にして、カスタムの重複メッセージチェックなしで完全な「正確に 1 回」の保証が提供されます。

トランザクションを外部で管理する必要がない場合は、JmsTransactionManager よりも "sessionTransacted" フラグを強くお勧めします。結果として、JTA を使用している場合、またはカスタムの外部トランザクション配置と同期する必要がある場合にのみ、トランザクションマネージャーを設定してください。

導入:
2.0
作成者:
Juergen Hoeller, Stephane Nicoll, Brian Clozel
関連事項:

  • コンストラクターの詳細

    • AbstractMessageListenerContainer

      public AbstractMessageListenerContainer()

  • メソッドの詳細

    • setConcurrency

      public abstract void setConcurrency(StringSE concurrency)
      同時実行制限を指定します。

    • setDestination

      public void setDestination(@Nullable DestinationEE destination)
      メッセージの送信先を設定します。

      または、"destinationName" を指定して、DestinationResolver を介して動的に解決します。

      メモ: 宛先は実行時に置き換えられ、リスナーコンテナーが新しい宛先をすぐに取得します（たとえば、キャッシュレベルが CACHE_CONSUMER 未満である限り、DefaultMessageListenerContainer で機能します）。ただし、これは高度な使用箇所と見なされます。注意して使用してください！

      関連事項:

    • getDestination

      @Nullable public DestinationEE getDestination()
      メッセージを受け取る宛先を返します。構成された宛先が実際の DestinationEE 型でない場合は、null になります。c.f. when the destination is a String。

    • setDestinationName

      public void setDestinationName(@Nullable StringSE destinationName)
      メッセージを受信する宛先の名前を設定します。

      指定された名前は、構成された destination resolver を介して動的に解決されます。

      または、JMS DestinationEE オブジェクトを「宛先」として指定します。

      メモ: 宛先は実行時に置き換えられ、リスナーコンテナーが新しい宛先をすぐに取得します（たとえば、キャッシュレベルが CACHE_CONSUMER 未満である限り、DefaultMessageListenerContainer で機能します）。ただし、これは高度な使用箇所と見なされます。注意して使用してください！

      関連事項:

    • getDestinationName

      @Nullable public StringSE getDestinationName()
      メッセージを受信する宛先の名前を返します。構成された宛先が StringSE 型でない場合、null になります。c.f. when it is an actual Destination。

    • getDestinationDescription

      protected StringSE getDestinationDescription()
      このコンテナーの JMS 宛先を説明する文字列を返します（決して null ではありません）。

    • setMessageSelector

      public void setMessageSelector(@Nullable StringSE messageSelector)
      JMS メッセージセレクター式を設定します（ない場合は null）。デフォルトはなしです。

      セレクター式の詳細な定義については、JMS 仕様を参照してください。

      メモ: メッセージセレクターは実行時に置き換えられ、リスナーコンテナーは新しいセレクター値をすぐに取得します（たとえば、キャッシュレベルが CACHE_CONSUMER 未満である限り、DefaultMessageListenerContainer で機能します）。ただし、これは高度な使用箇所と見なされます。注意して使用してください！

    • getMessageSelector

      @Nullable public StringSE getMessageSelector()
      JMS メッセージセレクター式（ない場合は null）を返します。

    • setMessageListener

      public void setMessageListener(@Nullable ObjectSE messageListener)
      登録するメッセージリスナーの実装を設定します。これは、標準の JMS MessageListenerEE オブジェクトまたは Spring SessionAwareMessageListener オブジェクトのいずれかです。

      メモ: メッセージリスナーは実行時に置き換えられ、リスナーコンテナーは新しいリスナーオブジェクトをすぐに取得します（たとえば、キャッシュレベルが CACHE_CONSUMER 未満である限り、DefaultMessageListenerContainer で動作します）。ただし、これは高度な使用箇所と見なされます。注意して使用してください！

      例外:
      IllegalArgumentExceptionSE - 指定されたリスナーが MessageListenerEE でも SessionAwareMessageListener でもない場合
      関連事項:

    • getMessageListener

      @Nullable public ObjectSE getMessageListener()
      登録するメッセージリスナーオブジェクトを返します。

    • checkMessageListener

      protected void checkMessageListener(@Nullable ObjectSE messageListener)
      指定されたメッセージリスナーを確認し、サポートされているリスナー型に対応していない場合は例外をスローします。

      デフォルトでは、標準の JMS MessageListenerEE オブジェクトまたは Spring SessionAwareMessageListener オブジェクトのみが受け入れられます。

      パラメーター:
      messageListener - チェックするメッセージリスナーオブジェクト
      例外:
      IllegalArgumentExceptionSE - 指定されたリスナーが MessageListenerEE でも SessionAwareMessageListener でもない場合
      関連事項:

    • getDefaultSubscriptionName

      protected StringSE getDefaultSubscriptionName(ObjectSE messageListener)
      指定されたメッセージリスナーのデフォルトのサブスクリプション名を決定します。
      パラメーター:
      messageListener - チェックするメッセージリスナーオブジェクト
      戻り値:
      デフォルトのサブスクリプション名
      関連事項:

    • setSubscriptionDurable

      public void setSubscriptionDurable(boolean subscriptionDurable)
      サブスクリプションを永続的にするかどうかを設定します。使用する永続サブスクリプション名は、"subscriptionName" プロパティで指定できます。

      デフォルトは "false" です。これを "true" に設定して、通常は "subscriptionName" 値と組み合わせて永続サブスクリプションを登録します（メッセージリスナクラス名がサブスクリプション名として十分である場合を除く）。

      トピック（pub-sub ドメイン）をリスニングしている場合にのみ意味があるため、このメソッドは "pubSubDomain" フラグも切り替えます。

      関連事項:

    • isSubscriptionDurable

      public boolean isSubscriptionDurable()
      サブスクリプションを永続的にするかどうかを返します。

    • setSubscriptionShared

      public void setSubscriptionShared(boolean subscriptionShared)
      サブスクリプションを共有するかどうかを設定します。使用する共有サブスクリプション名は、"subscriptionName" プロパティで指定できます。

      デフォルトは "false" です。共有サブスクリプションを登録するには、これを "true" に設定します。通常、"subscriptionName" 値と組み合わせて（メッセージリスナークラス名がサブスクリプション名として十分である場合を除く）。共有サブスクリプションも永続的である可能性があるため、このフラグは "subscriptionDurable" と組み合わせることもできます（多くの場合、組み合わせられます）。

      トピック（pub-sub ドメイン）をリスニングしている場合にのみ意味があるため、このメソッドは "pubSubDomain" フラグも切り替えます。

      JMS 2.0 互換のメッセージブローカーが必要です。

      導入:
      4.1
      関連事項:

    • isSubscriptionShared

      public boolean isSubscriptionShared()
      サブスクリプションを共有するかどうかを返します。
      導入:
      4.1

    • setSubscriptionName

      public void setSubscriptionName(@Nullable StringSE subscriptionName)
      作成するサブスクリプションの名前を設定します。共有または永続サブスクリプションを持つトピック（pub-sub ドメイン）の場合に適用されます。

      サブスクリプション名は、このクライアントの JMS クライアント ID 内で一意である必要があります。デフォルトは、指定されたメッセージリスナーのクラス名です。

      メモ: 共有サブスクリプション（JMS 2.0 が必要）を除き、各サブスクリプションで許可される同時コンシューマーは 1 つ（このメッセージリスナーコンテナーのデフォルト）です。

      導入:
      4.1
      関連事項:

    • getSubscriptionName

      @Nullable public StringSE getSubscriptionName()
      作成するサブスクリプションの名前を返します（ある場合）。
      導入:
      4.1

    • setDurableSubscriptionName

      public void setDurableSubscriptionName(@Nullable StringSE durableSubscriptionName)
      作成する永続サブスクリプションの名前を設定します。このメソッドは pub-sub ドメインモードに切り替え、サブスクリプションの永続化もアクティブ化します。

      永続サブスクリプション名は、このクライアントの JMS クライアント ID 内で一意である必要があります。デフォルトは、指定されたメッセージリスナーのクラス名です。

      メモ: 共有永続サブスクリプション（JMS 2.0 が必要）を除いて、各永続サブスクリプションで許可される同時コンシューマーは 1 つだけです（これはこのメッセージリスナーコンテナーのデフォルトです）。

      関連事項:

    • getDurableSubscriptionName

      @Nullable public StringSE getDurableSubscriptionName()
      作成する永続サブスクリプションの名前を返します（存在する場合）。

    • setPubSubNoLocal

      public void setPubSubNoLocal(boolean pubSubNoLocal)
      独自の接続によって公開されたメッセージの配信を禁止するかどうかを設定します。デフォルトは "false" です。
      導入:
      4.1
      関連事項:

    • isPubSubNoLocal

      public boolean isPubSubNoLocal()
      独自の接続によって公開されたメッセージの配信を禁止するかどうかを返します。
      導入:
      4.1

    • setReplyPubSubDomain

      public void setReplyPubSubDomain(boolean replyPubSubDomain)
      返信先の種類を設定します。デフォルトでは、構成された pubSubDomain 値が使用されます（JmsDestinationAccessor.isPubSubDomain() を参照）。

      この設定は、動的宛先が有効な場合に解決する宛先の型を主に示します。

      パラメーター:
      replyPubSubDomain - パブリッシュ / サブスクライブドメイン（TopicsEE）の場合は "true"、ポイントツーポイントドメインの場合は "false" ( QueuesEE )
      導入:
      4.2
      関連事項:

    • isReplyPubSubDomain

      public boolean isReplyPubSubDomain()
      パブリッシュ / サブスクライブドメイン（TopicsEE）が返信に使用されるかどうかを返します。それ以外の場合は、ポイントツーポイントドメイン（QueuesEE）が使用されます。
      次で指定:
      インターフェース MessageListenerContainer の isReplyPubSubDomain 
      導入:
      4.2

    • setReplyQosSettings

      public void setReplyQosSettings(@Nullable QosSettings replyQosSettings)
      返信を送信するときに使用する QosSettings を構成します。null に設定して、ブローカーのデフォルトを使用する必要があることを示すことができます。
      パラメーター:
      replyQosSettings - 応答を送信するときに使用する QoS 設定、またはデフォルト値を使用する null 
      導入:
      5.0

    • getReplyQosSettings

      @Nullable public QosSettings getReplyQosSettings()
      インターフェースからコピーされた説明: MessageListenerContainer
      応答を送信するときに使用する QosSettings を返すか、ブローカーのデフォルトを使用する必要がある場合は null を返します。
      次で指定:
      インターフェース MessageListenerContainer の getReplyQosSettings 

    • setMessageConverter

      public void setMessageConverter(@Nullable MessageConverter messageConverter)
      JMS メッセージを変換するための MessageConverter 戦略を設定します。
      導入:
      4.1

    • getMessageConverter

      @Nullable public MessageConverter getMessageConverter()
      インターフェースからコピーされた説明: MessageListenerContainer
      MessageEE があれば、それを変換するために使用できる MessageConverter を返します。
      次で指定:
      インターフェース MessageListenerContainer の getMessageConverter 

    • setExceptionListener

      public void setExceptionListener(@Nullable ExceptionListenerEE exceptionListener)
      登録されたメッセージリスナーまたは呼び出しインフラストラクチャによって JMSException がスローされた場合に通知するように JMS ExceptionListener を設定します。

    • getExceptionListener

      @Nullable public ExceptionListenerEE getExceptionListener()
      登録されたメッセージリスナーまたは呼び出しインフラストラクチャ（存在する場合）によって JMSException がスローされた場合に通知する JMS ExceptionListener を返します。

    • setErrorHandler

      public void setErrorHandler(@Nullable ErrorHandler errorHandler)
      MessageEE の処理中にスローされたキャッチされない例外が発生した場合に呼び出される ErrorHandler を設定します。

      デフォルトでは、ErrorHandler は存在しないため、エラーレベルのログが唯一の結果になります。

    • getErrorHandler

      @Nullable public ErrorHandler getErrorHandler()
      MessageEE の処理中にスローされたキャッチされない例外が発生した場合に呼び出される ErrorHandler を返します。
      導入:
      4.1

    • setObservationRegistry

      public void setObservationRegistry(@Nullable io.micrometer.observation.ObservationRegistry observationRegistry)
      JMS message processing observations の記録に使用する ObservationRegistry を設定します。レジストリが設定されていない場合は、デフォルトで no-op 監視になります。
      導入:
      6.1

    • getObservationRegistry

      @Nullable public io.micrometer.observation.ObservationRegistry getObservationRegistry()
      JMS message processing observations の記録に使用された ObservationRegistry を返します。
      導入:
      6.1

    • setExposeListenerSession

      public void setExposeListenerSession(boolean exposeListenerSession)
      リスナー JMS セッションを登録済みの SessionAwareMessageListener および JmsTemplate 呼び出しに公開するかどうかを設定します。

      デフォルトは "true" で、リスナーの SessionEE を再利用します。これをオフにすると、一部の JMS プロバイダーで必要になる可能性のある、同じ基礎となる JMS ConnectionEE からフェッチされた新しい JMS セッションが公開されます。

      外部トランザクションマネージャーによって管理されるセッションは、常に JmsTemplate 呼び出しに公開されることに注意してください。JmsTemplate 露出に関しては、この設定はローカルでトランザクション処理されたセッションにのみ影響します。

      関連事項:

    • isExposeListenerSession

      public boolean isExposeListenerSession()
      リスナー JMS SessionEE を登録済みの SessionAwareMessageListener に公開するかどうかを返します。

    • setAcceptMessagesWhileStopping

      public void setAcceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)
      リスナコンテナーの停止中に受信メッセージを受け入れるかどうかを設定します。

      デフォルトは "false" で、受信の試行を中止することでそのようなメッセージを拒否します。停止フェーズでもこのようなメッセージを完全に処理するには、このフラグをオンにします。ただし、新しく送信されたメッセージでも処理される可能性があるという欠点があります（すべての受信タイムアウトが期限切れになる前に受信した場合）。

      注意 : このような受信メッセージの受信試行を中止すると、影響を受けるメッセージのプロバイダーの再試行回数が減少する可能性があります。同時コンシューマーの数が多い場合は、すべての潜在的な停止シナリオで安全を確保するために、リトライの数がコンシューマーの数よりも多いことを確認してください。

    • isAcceptMessagesWhileStopping

      public boolean isAcceptMessagesWhileStopping()
      リスナーコンテナーが停止している間に受信メッセージを受け入れるかどうかを返します。

    • validateConfiguration

      protected void validateConfiguration()
      クラスからコピーされた説明: AbstractJmsListeningContainer
      このコンテナーの構成を検証します。

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

      オーバーライド:
      クラス AbstractJmsListeningContainer の validateConfiguration 

    • setupMessageListener

      public void setupMessageListener(ObjectSE messageListener)
      インターフェースからコピーされた説明: MessageListenerContainer
      使用するメッセージリスナーを設定します。そのメッセージリスナー型がサポートされていない場合、IllegalArgumentExceptionSE をスローします。
      次で指定:
      インターフェース MessageListenerContainer の setupMessageListener 

    • executeListener

      protected void executeListener(SessionEE session, MessageEE message)
      指定されたリスナーを実行し、後でトランザクションをコミットまたはロールバックします（必要な場合）。
      パラメーター:
      session - 操作する JMS セッション
      message - 受信した JMS MessageEE
      関連事項:

    • createObservation

      protected io.micrometer.observation.Observation createObservation(MessageEE message)

    • doExecuteListener

      protected void doExecuteListener(SessionEE session, MessageEE message) throws JMSExceptionEE
      指定されたリスナーを実行し、後でトランザクションをコミットまたはロールバックします（必要な場合）。
      パラメーター:
      session - 操作する JMS セッション
      message - 受信した JMS MessageEE
      例外:
      JMSExceptionEE - JMS API メソッドによってスローされた場合
      関連事項:

    • invokeListener

      protected void invokeListener(SessionEE session, MessageEE message) throws JMSExceptionEE
      指定されたリスナーを呼び出す: 標準的な JMS の MessageListener または、（できれば）Spring の SessionAwareMessageListener。
      パラメーター:
      session - 操作する JMS セッション
      message - 受信した JMS MessageEE
      例外:
      JMSExceptionEE - JMS API メソッドによってスローされた場合
      関連事項:

    • doInvokeListener

      protected void doInvokeListener(SessionAwareMessageListener listener, SessionEE session, MessageEE message) throws JMSExceptionEE
      指定されたリスナーを Spring SessionAwareMessageListener として呼び出し、要求された場合は新しい JMS セッションを（潜在的に独自のトランザクションで）リスナーに公開します。
      パラメーター:
      listener - 呼び出す Spring SessionAwareMessageListener
      session - 操作する JMS セッション
      message - 受信した JMS MessageEE
      例外:
      JMSExceptionEE - JMS API メソッドによってスローされた場合
      関連事項:

    • doInvokeListener

      protected void doInvokeListener(MessageListenerEE listener, MessageEE message) throws JMSExceptionEE
      指定されたリスナーを標準の JMS MessageListenerEE として呼び出します。

      デフォルトの実装では、onMessage メソッドの単純な呼び出しを実行します。

      パラメーター:
      listener - 呼び出す JMS MessageListener 
      message - 受信した JMS MessageEE
      例外:
      JMSExceptionEE - JMS API メソッドによってスローされた場合
      関連事項:

    • commitIfNecessary

      protected void commitIfNecessary(SessionEE session, @Nullable MessageEE message) throws JMSExceptionEE
      必要に応じて、コミットまたはメッセージ確認を実行します。
      パラメーター:
      session - コミットする JMS SessionEE
      message - MessageEE が確認する
      例外:
      JMSExceptionEE - コミット失敗の場合

    • rollbackIfNecessary

      protected void rollbackIfNecessary(SessionEE session) throws JMSExceptionEE
      必要に応じて、ロールバックを実行します。
      パラメーター:
      session - ロールバックする JMS セッション
      例外:
      JMSExceptionEE - ロールバックエラーの場合

    • rollbackOnExceptionIfNecessary

      protected void rollbackOnExceptionIfNecessary(SessionEE session, ThrowableSE ex) throws JMSExceptionEE
      ロールバックを実行し、ロールバック例外を適切に処理します。
      パラメーター:
      session - ロールバックする JMS セッション
      ex - スローされたアプリケーションの例外またはエラー
      例外:
      JMSExceptionEE - ロールバックエラーの場合

    • isSessionLocallyTransacted

      protected boolean isSessionLocallyTransacted(SessionEE session)
      指定されたセッションがローカルでトランザクション処理されているかどうか、つまり、そのトランザクションが外部リスナーのコーディネーターではなく、このリスナーコンテナーのセッション処理によって管理されているかどうかを確認します。

      メモ: セッション自体のトランザクション済みフラグは、以前にすでにチェックされています。このメソッドは、セッションのトランザクションがローカルであるか、外部で調整されているかを確認するためのものです。

      パラメーター:
      session - チェックするセッション
      戻り値:
      指定されたセッションがローカルでトランザクションされるかどうか
      関連事項:

    • createConsumer

      protected MessageConsumerEE createConsumer(SessionEE session, DestinationEE destination) throws JMSExceptionEE
      指定されたセッションと宛先の JMS MessageConsumer を作成します。

      この実装では、JMS 1.1 API を使用します。

      パラメーター:
      session - MessageConsumer を作成する JMS セッション
      destination - MessageConsumer を作成する JMS 宛先
      戻り値:
      新しい JMS MessageConsumer
      例外:
      JMSExceptionEE - JMS API メソッドによってスローされた場合

    • handleListenerException

      protected void handleListenerException(ThrowableSE ex)
      リスナーの実行中に発生した特定の例外を処理します。

      デフォルトの実装では、例外を JMS プロバイダーに伝播せずに、WARN レベルでログに記録します。確認応答やトランザクションのすべての処理がこのリスナーコンテナーによって行われると仮定します。これはサブクラスでオーバーライドできます。

      パラメーター:
      ex - 処理する例外

    • invokeExceptionListener

      protected void invokeExceptionListener(JMSExceptionEE ex)
      登録済みの JMS ExceptionListener があれば呼び出します。
      パラメーター:
      ex - JMS 処理中に発生した例外
      関連事項:

    • invokeErrorHandler

      protected void invokeErrorHandler(ThrowableSE ex)
      登録されている ErrorHandler がある場合はそれを呼び出します。それ以外の場合は、WARN レベルでログを記録します。
      パラメーター:
      ex - JMS 処理中に発生した捕捉されなかったエラー
      関連事項: