クラス AmqpOutboundEndpoint

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractMessageHandler
org.springframework.integration.handler.AbstractMessageProducingHandler
org.springframework.integration.handler.AbstractReplyProducingMessageHandler
org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint
org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint
実装済みのインターフェース一覧:
org.reactivestreams.Subscriber<Message<?>>, RabbitTemplate.ConfirmCallback, RabbitTemplate.ReturnsCallback, Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Lifecycle, Ordered, ComponentSourceAware, ExpressionCapable, Orderable, MessageProducer, HeaderPropagationAware, IntegrationPattern, NamedComponent, IntegrationManagement, ManageableLifecycle, TrackableComponent, MessageHandler, reactor.core.CoreSubscriber<Message<?>>
public class AmqpOutboundEndpoint extends AbstractAmqpOutboundEndpoint implements RabbitTemplate.ConfirmCallback, RabbitTemplate.ReturnsCallback
メッセージを変換して AMQPExchange に送信するアダプター。
導入:
2.1
作成者:
Mark Fisher, Oleg Zhurakousky, Gary Russell, Artem Bilan, Ngoc Nhan

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

    • AmqpOutboundEndpoint

      public AmqpOutboundEndpoint(AmqpTemplate amqpTemplate)

  • 方法の詳細

    • setExpectReply

      public void setExpectReply(boolean expectReply)
      このエンドポイントがゲートウェイの場合は true に設定します。
      パラメーター:
      expectReply - ゲートウェイの場合は true。

    • setWaitForConfirm

      public void setWaitForConfirm(boolean waitForConfirm)
      パブリッシャーの確認が受信されるまで呼び出しスレッドをブロックする場合は、true に設定します。return 用に構成されたテンプレートが必要です。確認タイムアウト内に確認が受信されない場合、または否定応答または返されたメッセージが受信された場合、例外がスローされます。ゲートウェイは応答の待機をブロックするため、ゲートウェイには適用されません。
      パラメーター:
      waitForConfirm - 確認またはタイムアウトが受信されるまでブロックする場合は true。
      導入:
      5.2
      関連事項:

    • getComponentType

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

    • setMultiSend

      public void setMultiSend(boolean multiSend)
      true で、メッセージペイロードが Message の IterableSE である場合、テンプレートの 1 回の呼び出し（同じチャネル）でメッセージを送信し、オプションで確認を待つか、終了するか、トランザクション内のすべての送信を実行します（既存または新規）。
      パラメーター:
      multiSend - 複数のメッセージを送信する場合は true。
      導入:
      5.3
      関連事項:

    • getIntegrationPatternType

      public IntegrationPatternType getIntegrationPatternType()
      インターフェースからコピーされた説明: IntegrationPattern
      このコンポーネントが実装するパターン型を返します。
      次で指定:
      インターフェース IntegrationPattern 内の getIntegrationPatternType 
      オーバーライド:
      クラス AbstractReplyProducingMessageHandler の getIntegrationPatternType 
      戻り値:
      このコンポーネントが実装する IntegrationPatternType

    • getRabbitTemplate

      public @Nullable RabbitTemplate getRabbitTemplate()
      次で指定:
      クラス AbstractAmqpOutboundEndpoint の getRabbitTemplate 

    • endpointInit

      protected void endpointInit()
      クラスからコピーされた説明: AbstractAmqpOutboundEndpoint
      サブクラスはオーバーライドして、追加の初期化を実行できます。afterPropertiesSet() から呼び出されます。
      オーバーライド:
      クラス AbstractAmqpOutboundEndpoint の endpointInit 

    • doStop

      protected void doStop()
      オーバーライド:
      クラス AbstractAmqpOutboundEndpoint の doStop 

    • handleRequestMessage

      protected @Nullable ObjectSE handleRequestMessage(Message<?> requestMessage)
      クラスからコピーされた説明: AbstractReplyProducingMessageHandler
      サブクラスはこのメソッドを実装して、リクエストメッセージを処理する必要があります。戻り値は、メッセージ、MessageBuilder、任意のプレーンオブジェクトです。基本クラスは、これらの開始点のいずれかからの返信メッセージの最終的な作成を処理します。戻り値が null の場合、メッセージフローはここで終了します。
      次で指定:
      クラス AbstractReplyProducingMessageHandler の handleRequestMessage 
      パラメーター:
      requestMessage - リクエストメッセージ。
      戻り値:
      メッセージを処理した結果、または null

    • confirm

      public void confirm(@Nullable CorrelationData correlationData, boolean ack, @Nullable StringSE cause)
      次で指定:
      インターフェース RabbitTemplate.ConfirmCallback 内の confirm 

    • returnedMessage

      public void returnedMessage(ReturnedMessage returnedMessage)
      次で指定:
      インターフェース RabbitTemplate.ReturnsCallback 内の returnedMessage