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

クラス JmsMessageDrivenEndpoint

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.MessageProducerSupport
org.springframework.integration.jms.JmsMessageDrivenEndpoint
実装されたすべてのインターフェース:
Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、SmartInitializingSingleton、ApplicationContextAware、Lifecycle、Phased、SmartLifecycle、ExpressionCapable、OrderlyShutdownCapable、MessageProducer、IntegrationPattern、NamedComponent、IntegrationInboundManagement、IntegrationManagement、ManageableLifecycle、ManageableSmartLifecycle、TrackableComponent
public class JmsMessageDrivenEndpoint extends MessageProducerSupport implements OrderlyShutdownCapable
JMS メッセージを受信し、Spring Integration メッセージに変換して、結果をチャネルに送信するメッセージ駆動型エンドポイント。
作成者:
Mark Fisher, Oleg Zhurakousky, Gary Russell, Artem Bilan

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

    • JmsMessageDrivenEndpoint

      public JmsMessageDrivenEndpoint(AbstractMessageListenerContainer listenerContainer, ChannelPublishingJmsMessageListener listener)
      外部で構成されたコンテナーを使用してインスタンスを作成します。
      パラメーター:
      listenerContainer - コンテナー。
      listener - リスナー。

  • メソッドの詳細

    • setSessionAcknowledgeMode

      public void setSessionAcknowledgeMode(StringSE sessionAcknowledgeMode)
      リスナーコンテナーでセッション確認モードを設定します。外部コンテナーが提供されている場合でも、コンテナー設定を上書きします。外部コンテナーが提供されている場合はデフォルトで null（コンテナーを変更しない）、またはフレームワークが暗黙の DefaultMessageListenerContainer を作成する場合は `transacted`。
      パラメーター:
      sessionAcknowledgeMode - 承認モード。

    • setOutputChannel

      public void setOutputChannel(MessageChannel outputChannel)
      インターフェースからコピーされた説明: MessageProducer
      生成されたメッセージの送信先となる MessageChannel を指定します。
      次で指定:
      インターフェース MessageProducer の setOutputChannel 
      オーバーライド:
      クラス MessageProducerSupport の setOutputChannel 
      パラメーター:
      outputChannel - 出力チャネル。

    • setOutputChannelName

      public void setOutputChannelName(StringSE outputChannelName)
      クラスからコピーされた説明: MessageProducerSupport
      出力チャネル名を設定します。提供されている場合、outputChannel をオーバーライドします。
      次で指定:
      インターフェース MessageProducer の setOutputChannelName 
      オーバーライド:
      クラス MessageProducerSupport の setOutputChannelName 
      パラメーター:
      outputChannelName - チャンネル名。

    • setErrorChannel

      public void setErrorChannel(MessageChannel errorChannel)
      オーバーライド:
      クラス MessageProducerSupport の setErrorChannel 

    • setErrorChannelName

      public void setErrorChannelName(StringSE errorChannelName)
      クラスからコピーされた説明: MessageProducerSupport
      エラーチャネル名を設定します。エラーチャネルが提供されていない場合、このエンドポイントは例外をメッセージ駆動型ソースに伝播します。例外を完全に抑制するには、ここで "nullChannel" への参照を提供します。
      オーバーライド:
      クラス MessageProducerSupport の setErrorChannelName 
      パラメーター:
      errorChannelName - エラーチャネル Bean 名。

    • setSendTimeout

      public void setSendTimeout(long sendTimeout)
      クラスからコピーされた説明: MessageProducerSupport
      送信操作に使用するデフォルトのタイムアウト値を構成します。個々のメッセージに対してオーバーライドされる場合があります。
      オーバーライド:
      クラス MessageProducerSupport の setSendTimeout 
      パラメーター:
      sendTimeout - 「送信」操作のタイムアウト (ミリ秒)
      関連事項:

    • setShouldTrack

      public void setShouldTrack(boolean shouldTrack)
      次で指定:
      インターフェース TrackableComponent の setShouldTrack 
      オーバーライド:
      クラス MessageProducerSupport の setShouldTrack 

    • setShutdownContainerOnStop

      public void setShutdownContainerOnStop(boolean shutdownContainerOnStop)
      エンドポイントが停止しているときにリスナーコンテナーがシャットダウンしないようにするには、false に設定します。そのように構成されている場合、コンテナー内のキャッシュされたコンシューマーはそのまま残ります。それ以外の場合、共有接続は閉じられ、リスナーの呼び出し元がシャットダウンされます。この動作は、バージョン 5.1 以降の新しい動作です。デフォルト: true。
      パラメーター:
      shutdownContainerOnStop - シャットダウンしない場合は false。
      導入:
      5.1

    • getListener

      public ChannelPublishingJmsMessageListener getListener()

    • registerMetricsCaptor

      public void registerMetricsCaptor(MetricsCaptor captor)
      インターフェースからコピーされた説明: IntegrationManagement
      MetricsCaptor を注入します。ObservationRegistry が指定されている場合は無視されます。
      次で指定:
      インターフェース IntegrationManagement の registerMetricsCaptor 
      パラメーター:
      captor - キャプター。
      関連事項:

    • registerObservationRegistry

      public void registerObservationRegistry(io.micrometer.observation.ObservationRegistry observationRegistry)
      インターフェースからコピーされた説明: IntegrationManagement
      ObservationRegistry を注入します。指定された場合、MetricsCaptor は無視されます。メーターのキャプチャーは、提供された ObservationRegistry で ObservationHandler として構成する必要があります。
      次で指定:
      インターフェース IntegrationManagement の registerObservationRegistry 
      オーバーライド:
      クラス MessageProducerSupport の registerObservationRegistry 
      パラメーター:
      observationRegistry - コンポーネントからの観察結果を公開する ObservationRegistry。
      関連事項:

    • setObservationConvention

      public void setObservationConvention(MessageReceiverObservationConvention observationConvention)
      クラスからコピーされた説明: MessageProducerSupport
      IntegrationObservation.HANDLER にカスタム MessageReceiverObservationConvention を設定します。このコンポーネントに対して ObservationRegistry が構成されていない場合は無視されます。
      オーバーライド:
      クラス MessageProducerSupport の setObservationConvention 
      パラメーター:
      observationConvention - 使用する MessageReceiverObservationConvention。

    • setApplicationContext

      public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
      次で指定:
      インターフェース ApplicationContextAware の setApplicationContext 
      オーバーライド:
      クラス IntegrationObjectSupport の setApplicationContext 
      例外:
      BeansException

    • getComponentType

      public StringSE getComponentType()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
      次で指定:
      インターフェース NamedComponent の getComponentType 
      オーバーライド:
      クラス IntegrationObjectSupport の getComponentType 

    • afterSingletonsInstantiated

      public void afterSingletonsInstantiated()
      次で指定:
      インターフェース SmartInitializingSingleton の afterSingletonsInstantiated 
      オーバーライド:
      クラス MessageProducerSupport の afterSingletonsInstantiated 

    • onInit

      protected void onInit()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスは、初期化ロジック用にこれを実装できます。
      オーバーライド:
      クラス MessageProducerSupport の onInit 

    • doStart

      protected void doStart()
      クラスからコピーされた説明: MessageProducerSupport
      デフォルトでは何もしません。サブクラスは、ライフサイクル管理の動作が必要な場合、これをオーバーライドできます。"lifecycleLock" によって保護されています。
      オーバーライド:
      クラス MessageProducerSupport の doStart 

    • doStop

      protected void doStop()
      クラスからコピーされた説明: MessageProducerSupport
      デフォルトでは何もしません。サブクラスは、ライフサイクル管理の動作が必要な場合、これをオーバーライドできます。
      オーバーライド:
      クラス MessageProducerSupport の doStop 

    • destroy

      public void destroy()
      次で指定:
      インターフェース DisposableBean の destroy 
      次で指定:
      インターフェース IntegrationManagement の destroy 
      オーバーライド:
      クラス AbstractEndpoint の destroy 

    • beforeShutdown

      public int beforeShutdown()
      インターフェースからコピーされた説明: OrderlyShutdownCapable
      シャットダウンが始まる前に呼び出されます。実装は、新しいメッセージの受け入れを停止する必要があります。オプションで、処理中のアクティブなメッセージの数を返すことができます。
      次で指定:
      インターフェース OrderlyShutdownCapable の beforeShutdown 
      戻り値:
      使用可能な場合、アクティブなメッセージの数。

    • afterShutdown

      public int afterShutdown()
      インターフェースからコピーされた説明: OrderlyShutdownCapable
      スケジューラー、エグゼキューターなどの通常のシャットダウンの後、シャットダウン遅延が経過した後、残りのアクティブなスケジューラー / エグゼキュータースレッドの強制シャットダウンの前に呼び出されます。オプションで、まだ処理中のアクティブなメッセージの数を返すことができます。
      次で指定:
      インターフェース OrderlyShutdownCapable の afterShutdown 
      戻り値:
      使用可能な場合、アクティブなメッセージの数。