クラス AmqpInboundGateway

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

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

  • 方法の詳細

    • setMessageConverter

      public void setMessageConverter(MessageConverter messageConverter)
      MessageConverter を指定して、リクエストを変換し、Message との間で応答します。amqpTemplate が明示的に設定されている場合、この MessageConverter はそこに入力されません。その外部 amqpTemplate を構成する必要があります。
      パラメーター:
      messageConverter - 使用する MessageConverter。

    • setHeaderMapper

      public void setHeaderMapper(AmqpHeaderMapper headerMapper)

    • setDefaultReplyTo

      public void setDefaultReplyTo(StringSE defaultReplyTo)
      次の形式の defaultReplyTo アドレス 
      (exchange)/(routingKey)
      または 
      (queueName)
      リクエストメッセージに replyTo プロパティがない場合。2 番目の形式は、デフォルトの交換（""）とキュー名をルーティングキーとして使用します。
      パラメーター:
      defaultReplyTo - 使用するデフォルトの replyTo アドレス。
      導入:
      4.2
      関連事項:

    • 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)
      メッセージをバッチ解除するときに使用するバッチ処理戦略を設定します。デフォルトは SimpleBatchingStrategy です。
      パラメーター:
      batchingStrategy - 戦略。
      導入:
      5.2

    • setBindSourceMessage

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

    • setReplyHeadersMappedLast

      public void setReplyHeadersMappedLast(boolean replyHeadersMappedLast)
      送信（返信）メッセージのヘッダーをマッピングする際に、ヘッダーをメッセージの変換前にマッピングするか、変換後にマッピングするかを指定します。これは、メッセージコンバーターによって追加される可能性のあるヘッダーにのみ影響します。false の場合、コンバーターのヘッダーが優先されます。true の場合、コンバーターによって追加されたヘッダーは上書きされます（ソースメッセージにそれらのヘッダーにマッピングされるヘッダーがある場合）。たとえば、JSON を含む文字列ペイロードで SimpleMessageConverter を使用する場合、これを true に設定すると、コンバーターはコンテンツ型を text/plain に設定しますが、AmqpHeaders.CONTENT_TYPE メッセージヘッダーを設定することで、これは application/json に上書きできます。デフォルト: false。
      パラメーター:
      replyHeadersMappedLast - 変換後に応答ヘッダーがマップされる場合は true。
      導入:
      5.1.9

    • getComponentType

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

    • onInit

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

    • doStart

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

    • doStop

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

    • getErrorMessageAttributes

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