クラス AmqpClientMessageProducer

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

RabbitAmqpListenerContainer に基づいており、AmqpConnectionFactory が必要です。

導入:
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)

    • setBatchSize

      public void setBatchSize(int batchSize)

    • setBatchReceiveTimeout

      public void setBatchReceiveTimeout(long batchReceiveTimeout)

    • setTaskScheduler

      public void setTaskScheduler(TaskScheduler taskScheduler)
      クラスからコピーされた説明: IntegrationObjectSupport
      ロジックがスケジュールされたタスクに依存するコンポーネントの TaskScheduler を構成します。提供されていない場合は、Spring Integration インフラストラクチャによって提供されるアプリケーションコンテキストのグローバル taskScheduler Bean にフォールバックします。
      オーバーライド:
      クラス IntegrationObjectSupport の setTaskScheduler 
      パラメーター:
      taskScheduler - 使用する TaskScheduler。
      関連事項:

    • 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 ペイロードに送信されます。
      パラメーター:
      messageConverter - 使用する MessageConverter または null。

    • setHeaderMapper

      public void setHeaderMapper(AmqpHeaderMapper headerMapper)

    • 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 

    • destroy

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

    • pause

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

    • resume

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

    • isPaused

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