クラス AmqpInboundChannelAdapter

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.MessageProducerSupport
org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter
実装済みのインターフェース一覧:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, SmartInitializingSingleton, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, ComponentSourceAware, ExpressionCapable, OrderlyShutdownCapable, MessageProducer, IntegrationPattern, NamedComponent, IntegrationInboundManagement, IntegrationManagement, ManageableLifecycle, ManageableSmartLifecycle, TrackableComponent
public class AmqpInboundChannelAdapter extends MessageProducerSupport implements OrderlyShutdownCapable
AMQP キューからメッセージを受信し、それを Spring Integration メッセージに変換し、結果をメッセージチャネルに送信するアダプター。
導入:
2.1
作成者:
Mark Fisher, Gary Russell, Artem Bilan, Ngoc Nhan

  • フィールドの詳細

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

    • AmqpInboundChannelAdapter

      @DeprecatedSE(forRemoval=true, since="7.1") public AmqpInboundChannelAdapter(MessageListenerContainer listenerContainer)
      非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
      AmqpInboundChannelAdapter(org.springframework.amqp.core.MessageListenerContainer) を推奨する 7.1 以降。
      提供されたコンテナーを使用してインスタンスを構築します。バイトコードの下位互換性のために必要です。
      パラメーター:
      listenerContainer - コンテナー。

    • AmqpInboundChannelAdapter

      public AmqpInboundChannelAdapter(MessageListenerContainer listenerContainer)
      提供されたコンテナーを使用してインスタンスを構築します。
      パラメーター:
      listenerContainer - コンテナー。

  • 方法の詳細

    • setMessageConverter

      public void setMessageConverter(MessageConverter messageConverter)

    • setHeaderMapper

      public void setHeaderMapper(AmqpHeaderMapper headerMapper)

    • setRetryTemplate

      public void setRetryTemplate(RetryTemplate retryTemplate)
      アダプター内でメッセージ配信を再試行するために使用する RetryTemplate を設定します。コンテナーレベルで再試行を追加する場合とは異なり、ErrorMessageSendingRecoverer RecoveryCallback と組み合わせて使用することで、再試行回数の上限に達した後にエラーチャネルにパブリッシュできます。通常、ここで再試行を使用する場合はエラーチャネルを設定せず、代わりに RecoveryCallback を使用してください。
      パラメーター:
      retryTemplate - テンプレート。
      導入:
      4.3.10.
      関連事項:

    • setRecoveryCallback

      public void setRecoveryCallback(RecoveryCallback<?> recoveryCallback)
      アダプター内で再試行を使用する場合は、RecoveryCallback を設定します。setMessageRecoverer(MessageRecoverer) とは排他的です。
      パラメーター:
      recoveryCallback - コールバック。
      導入:
      4.3.10
      関連事項:

    • setMessageRecoverer

      public void setMessageRecoverer(MessageRecoverer messageRecoverer)
      再試行操作用に MessageRecoverer を構成します。setRecoveryCallback(RecoveryCallback) の代わりに AMQP 固有の便利さ。
      パラメーター:
      messageRecoverer - 使用する MessageRecoverer。
      導入:
      5.5

    • setBatchingStrategy

      public void setBatchingStrategy(BatchingStrategy batchingStrategy)
      バッチプロデューサー（BatchingRabbitTemplate など）によって作成されたメッセージをバッチ解除するときに使用するバッチ戦略を設定します。デフォルトは SimpleBatchingStrategy です。
      パラメーター:
      batchingStrategy - 戦略。
      導入:
      5.2

    • setBindSourceMessage

      public void setBindSourceMessage(boolean bindSourceMessage)
      IntegrationMessageHeaderAccessor.SOURCE_DATA という名前のヘッダーのソースメッセージをバインドするには、true に設定します。
      パラメーター:
      bindSourceMessage - バインドする場合は true。
      導入:
      5.1.6

    • setBatchMode

      public void setBatchMode(AmqpInboundChannelAdapter.BatchMode batchMode)
      リスナーコンテナーが consumerBatchEnabled で構成されている場合は、バッチ用に生成されたメッセージのペイロード型を設定します。デフォルトは AmqpInboundChannelAdapter.BatchMode.MESSAGES です。
      パラメーター:
      batchMode - バッチモード。
      導入:
      5.3

    • setHeaderNameForBatchedHeaders

      public void setHeaderNameForBatchedHeaders(StringSE headerNameForBatchedHeaders)
      バッチモードが AmqpInboundChannelAdapter.BatchMode.EXTRACT_PAYLOADS_WITH_HEADERS の場合、List<Map<String, Object> ヘッダーを含むヘッダー名を設定します。デフォルトは CONSOLIDATED_HEADERS です。
      パラメーター:
      headerNameForBatchedHeaders - バッチモードが AmqpInboundChannelAdapter.BatchMode.EXTRACT_PAYLOADS_WITH_HEADERS の場合の List<Map<String, Object> ヘッダーを含むヘッダーの名前。
      導入:
      6.4

    • getComponentType

      public StringSE getComponentType()
      次で指定:
      インターフェース NamedComponent 内の getComponentType 
      オーバーライド:
      クラス MessageProducerSupport の getComponentType 

    • onInit

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

    • doStart

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

    • doStop

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

    • beforeShutdown

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

    • afterShutdown

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

    • getErrorMessageAttributes

      protected AttributeAccessor getErrorMessageAttributes(@Nullable Message<?> message)
      クラスからコピーされた説明: MessageProducerSupport
      errorMessageStrategy でエラーメッセージを作成するときに使用する AttributeAccessor を設定します。
      オーバーライド:
      クラス MessageProducerSupport の getErrorMessageAttributes 
      パラメーター:
      message - メッセージ。
      戻り値:
      属性。