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

クラス JmsInboundGateway

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.gateway.MessagingGatewaySupport
org.springframework.integration.jms.JmsInboundGateway
実装されたすべてのインターフェース:
Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、Lifecycle、Phased、SmartLifecycle、ExpressionCapable、OrderlyShutdownCapable、IntegrationPattern、NamedComponent、IntegrationInboundManagement、IntegrationManagement、ManageableLifecycle、ManageableSmartLifecycle、TrackableComponent
public class JmsInboundGateway extends MessagingGatewaySupport implements OrderlyShutdownCapable
MessagingGatewaySupport を実装する JmsMessageDrivenEndpoint のラッパー。
導入:
5.0
作成者:
Artem Bilan, Gary Russell

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

  • メソッドの詳細

    • setRequestChannel

      public void setRequestChannel(MessageChannel requestChannel)
      クラスからコピーされた説明: MessagingGatewaySupport
      リクエストチャネルを設定します。
      オーバーライド:
      クラス MessagingGatewaySupport の setRequestChannel 
      パラメーター:
      requestChannel - リクエストメッセージの送信先のチャネル

    • setRequestChannelName

      public void setRequestChannelName(StringSE requestChannelName)
      クラスからコピーされた説明: MessagingGatewaySupport
      リクエストチャンネル名を設定します。
      オーバーライド:
      クラス MessagingGatewaySupport の setRequestChannelName 
      パラメーター:
      requestChannelName - リクエストメッセージの送信先となるチャネル Bean 名

    • setReplyChannel

      public void setReplyChannel(MessageChannel replyChannel)
      クラスからコピーされた説明: MessagingGatewaySupport
      返信チャンネルを設定します。応答チャネルが提供されていない場合、このゲートウェイは常に匿名の一時チャネルを使用して応答を処理します。
      オーバーライド:
      クラス MessagingGatewaySupport の setReplyChannel 
      パラメーター:
      replyChannel - 返信メッセージの受信元のチャネル

    • setReplyChannelName

      public void setReplyChannelName(StringSE replyChannelName)
      クラスからコピーされた説明: MessagingGatewaySupport
      返信チャンネル名を設定します。応答チャネルが提供されていない場合、このゲートウェイは常に匿名の一時チャネルを使用して応答を処理します。
      オーバーライド:
      クラス MessagingGatewaySupport の setReplyChannelName 
      パラメーター:
      replyChannelName - 応答メッセージの受信元となるチャネル Bean 名

    • setErrorChannel

      public void setErrorChannel(MessageChannel errorChannel)
      クラスからコピーされた説明: MessagingGatewaySupport
      エラーチャンネルを設定します。エラーチャネルが提供されていない場合、このゲートウェイは例外を呼び出し元に伝達します。例外を完全に抑制するには、ここで "nullChannel" への参照を提供します。
      オーバーライド:
      クラス MessagingGatewaySupport の setErrorChannel 
      パラメーター:
      errorChannel - エラーチャネル。

    • setErrorChannelName

      public void setErrorChannelName(StringSE errorChannelName)
      クラスからコピーされた説明: MessagingGatewaySupport
      エラーチャネル名を設定します。エラーチャネルが提供されていない場合、このゲートウェイは例外を呼び出し元に伝達します。例外を完全に抑制するには、ここで "nullChannel" への参照を提供します。
      オーバーライド:
      クラス MessagingGatewaySupport の setErrorChannelName 
      パラメーター:
      errorChannelName - エラーチャネル Bean 名。

    • setRequestTimeout

      public void setRequestTimeout(long requestTimeout)
      クラスからコピーされた説明: MessagingGatewaySupport
      リクエストメッセージを送信するためのタイムアウト値を設定します。明示的に設定されていない場合、デフォルトは 1 秒です。
      オーバーライド:
      クラス MessagingGatewaySupport の setRequestTimeout 
      パラメーター:
      requestTimeout - ミリ秒単位のタイムアウト値

    • setReplyTimeout

      public void setReplyTimeout(long replyTimeout)
      クラスからコピーされた説明: MessagingGatewaySupport
      応答メッセージを受信するためのタイムアウト値を設定します。明示的に設定されていない場合、デフォルトは 1 秒です。
      オーバーライド:
      クラス MessagingGatewaySupport の setReplyTimeout 
      パラメーター:
      replyTimeout - ミリ秒単位のタイムアウト値

    • setErrorOnTimeout

      public void setErrorOnTimeout(boolean errorOnTimeout)
      クラスからコピーされた説明: MessagingGatewaySupport
      errorOnTimeout が true の場合、応答が期待されても何も受信されない場合に、MessageTimeoutException ペイロードを含む ErrorMessage をエラーチャネルに送信するインスタンスを作成します。エラーチャネルが設定されていない場合、MessageTimeoutException がスローされます。
      オーバーライド:
      クラス MessagingGatewaySupport の setErrorOnTimeout 
      パラメーター:
      errorOnTimeout - true の場合、応答タイムアウト時にエラーメッセージを作成します。

    • setShouldTrack

      public void setShouldTrack(boolean shouldTrack)
      クラスからコピーされた説明: MessagingGatewaySupport
      このゲートウェイを、送信操作または sendAndReceive 操作から発信されたメッセージのメッセージ履歴で追跡する必要があるかどうかを指定します。
      次で指定:
      インターフェース TrackableComponent の setShouldTrack 
      オーバーライド:
      クラス MessagingGatewaySupport の setShouldTrack 

    • setShutdownContainerOnStop

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

    • registerMetricsCaptor

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

    • registerObservationRegistry

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

    • setObservationConvention

      public void setObservationConvention(MessageRequestReplyReceiverObservationConvention observationConvention)
      オーバーライド:
      クラス MessagingGatewaySupport の setObservationConvention 

    • getComponentType

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

    • setApplicationContext

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

    • onInit

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

    • getListener

      public ChannelPublishingJmsMessageListener getListener()

    • doStart

      protected void doStart()
      クラスからコピーされた説明: AbstractEndpoint
      サブクラスは、開始動作でこのメソッドを実装する必要があります。このメソッドは、AbstractEndpoint.lifecycleLock を保持しているときに呼び出されます。
      オーバーライド:
      クラス MessagingGatewaySupport の doStart 

    • doStop

      protected void doStop()
      クラスからコピーされた説明: AbstractEndpoint
      サブクラスは、停止動作でこのメソッドを実装する必要があります。このメソッドは、AbstractEndpoint.lifecycleLock を保持しているときに呼び出されます。
      オーバーライド:
      クラス MessagingGatewaySupport の doStop 

    • destroy

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

    • beforeShutdown

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

    • afterShutdown

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