クラス AmqpClientInboundGateway

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.gateway.MessagingGatewaySupport
org.springframework.integration.amqp.inbound.AmqpClientInboundGateway
実装済みのインターフェース一覧:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, ComponentSourceAware, ExpressionCapable, Pausable, IntegrationPattern, NamedComponent, IntegrationInboundManagement, IntegrationManagement, ManageableLifecycle, ManageableSmartLifecycle, TrackableComponent
public class AmqpClientInboundGateway extends MessagingGatewaySupport implements Pausable
AMQP 1.0 クライアント用の MessagingGatewaySupport 実装。

RabbitAmqpListenerContainer をベースにしており、AmqpConnectionFactory が必要です。応答の送信には内部の RabbitAmqpTemplate が使用されます。

導入:
7.0
作成者:
Artem Bilan
関連事項:

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

  • 方法の詳細

    • setInitialCredits

      public void setInitialCredits(int initialCredits)

    • setPriority

      public void setPriority(int priority)

    • setStateListeners

      public void setStateListeners(com.rabbitmq.client.amqp.Resource.StateListener... stateListeners)

    • setAfterReceivePostProcessors

      public void setAfterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors)

    • setAdviceChain

      public void setAdviceChain(Advice... advices)

    • setAutoSettle

      public void setAutoSettle(boolean autoSettle)

    • setDefaultRequeue

      public void setDefaultRequeue(boolean defaultRequeue)

    • setGracefulShutdownPeriod

      public void setGracefulShutdownPeriod(DurationSE gracefulShutdownPeriod)

    • setConsumersPerQueue

      public void setConsumersPerQueue(int consumersPerQueue)

    • setMessageConverter

      public void setMessageConverter(@Nullable MessageConverter messageConverter)
      デフォルトの SimpleMessageConverter を置き換えるために MessageConverter を設定します。null に設定した場合、AMQP メッセージはそのまま Message ペイロードに送信されます。応答メッセージは、ペイロードとして AMQP メッセージを返す必要があります。
      パラメーター:
      messageConverter - 使用する MessageConverter または null。

    • setHeaderMapper

      public void setHeaderMapper(AmqpHeaderMapper headerMapper)

    • setReplyPostProcessor

      public void setReplyPostProcessor(ReplyPostProcessor replyPostProcessor)

    • setReplyExchange

      public void setReplyExchange(StringSE exchange)
      リクエストメッセージに replyTo アドレスが指定されていない場合、返信送信用のデフォルトの exchange を設定します。setReplyQueue(String) とは排他的です。
      パラメーター:
      exchange - 返信を送信するためのデフォルトの交換

    • setReplyRoutingKey

      public void setReplyRoutingKey(StringSE routingKey)
      リクエストメッセージに replyTo アドレスが指定されていない場合、返信送信用のデフォルトの routingKey を設定します。setReplyExchange(String) が指定されている場合にのみ使用されます。
      パラメーター:
      routingKey - 返信を送信するためのデフォルトのルーティングキー

    • setReplyQueue

      public void setReplyQueue(StringSE queue)
      リクエストメッセージに replyTo アドレスが指定されていない場合、返信送信用のデフォルトの queue を設定します。setReplyExchange(String) とは排他的です。
      パラメーター:
      queue - 返信を送信するためのデフォルトのキュー

    • 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 

    • destroy

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

    • pause

      public void pause()
      インターフェースからコピーされた説明: Pausable
      エンドポイントを一時停止します。
      次で指定:
      インターフェース Pausable 内の pause 

    • resume

      public void resume()
      インターフェースからコピーされた説明: Pausable
      一時停止した場合は、エンドポイントを再開します。
      次で指定:
      インターフェース Pausable 内の resume 

    • isPaused

      public boolean isPaused()
      インターフェースからコピーされた説明: Pausable
      エンドポイントが一時停止しているかどうかを確認します。
      次で指定:
      インターフェース Pausable 内の isPaused 
      戻り値:
      一時停止した場合は true。