クラス PointToPointSubscribableAmqpChannel

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.channel.AbstractMessageChannel
org.springframework.integration.amqp.channel.AbstractAmqpChannel
org.springframework.integration.amqp.channel.PointToPointSubscribableAmqpChannel
実装済みのインターフェース一覧:
ConnectionListener, Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, ComponentSourceAware, ExpressionCapable, IntegrationPattern, NamedComponent, IntegrationManagement, ManageableLifecycle, ManageableSmartLifecycle, TrackableComponent, MessageChannel, SubscribableChannel, InterceptableChannel
public class PointToPointSubscribableAmqpChannel extends AbstractAmqpChannel
AMQP キューを介した 1 対 1 サブスクリプションの AbstractSubscribableAmqpChannel 実装。

キュー名が指定されていない場合、チャネル Bean 名は、指定された AmqpAdmin（存在する場合）を介してキューを宣言するために内部的に使用されます。

導入:
2.1
作成者:
Mark Fisher, Artem Bilan

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

    • PointToPointSubscribableAmqpChannel

      public PointToPointSubscribableAmqpChannel(StringSE channelName, AbstractMessageListenerContainer container, AmqpTemplate amqpTemplate)
      指定された名前、コンテナー、テンプレートでインスタンスを作成します。メッセージがマップされる場合、デフォルトのヘッダーマッパーが使用されます。
      パラメーター:
      channelName - チャンネル名。
      container - コンテナー。
      amqpTemplate - テンプレート。
      関連事項:

    • PointToPointSubscribableAmqpChannel

      public PointToPointSubscribableAmqpChannel(StringSE channelName, AbstractMessageListenerContainer container, AmqpTemplate amqpTemplate, AmqpHeaderMapper outboundMapper, AmqpHeaderMapper inboundMapper)
      指定された名前、コンテナー、テンプレートでインスタンスを作成します。メッセージがマップされる場合、デフォルトのヘッダーマッパーが使用されます。
      パラメーター:
      channelName - チャンネル名。
      container - コンテナー。
      amqpTemplate - テンプレート。
      outboundMapper - 発信マッパー。
      inboundMapper - 受信マッパー。
      導入:
      4.3
      関連事項:

  • 方法の詳細

    • setQueueName

      public void setQueueName(StringSE queueName)
      使用するキュー名を指定します。これが指定されていない場合、キューの名前はチャネル名と同じになります。
      パラメーター:
      queueName - キュー名。

    • obtainQueueName

      protected StringSE obtainQueueName(StringSE channelName)

    • createDispatcher

      protected AbstractDispatcher createDispatcher()

    • getRoutingKey

      protected StringSE getRoutingKey()
      クラスからコピーされた説明: AbstractAmqpChannel
      サブクラスは、このメソッドをオーバーライドしてルーティングキーを返す場合があります。デフォルトでは、ルーティングキー（空の文字列）はありません。
      オーバーライド:
      クラス AbstractAmqpChannel の getRoutingKey 
      戻り値:
      ルーティングキー。

    • doDeclares

      protected void doDeclares()
      次で指定:
      クラス AbstractAmqpChannel の doDeclares 

    • setMaxSubscribers

      public void setMaxSubscribers(int maxSubscribers)
      チャネルのディスパッチャーでサポートされるサブスクライバーの最大数を指定します（AbstractDispatcher の場合）。
      パラメーター:
      maxSubscribers - 許可されるサブスクライバーの最大数。

    • subscribe

      public boolean subscribe(MessageHandler handler)
      次で指定:
      インターフェース SubscribableChannel 内の subscribe 

    • unsubscribe

      public boolean unsubscribe(MessageHandler handler)
      次で指定:
      インターフェース SubscribableChannel 内の unsubscribe 

    • onInit

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

    • isAutoStartup

      public boolean isAutoStartup()
      次で指定:
      インターフェース SmartLifecycle 内の isAutoStartup 

    • getPhase

      public int getPhase()
      次で指定:
      インターフェース Phased 内の getPhase 
      次で指定:
      インターフェース SmartLifecycle 内の getPhase 

    • isRunning

      public boolean isRunning()
      次で指定:
      インターフェース Lifecycle 内の isRunning 
      次で指定:
      インターフェース ManageableLifecycle 内の isRunning 

    • start

      public void start()
      次で指定:
      インターフェース Lifecycle 内の start 
      次で指定:
      インターフェース ManageableLifecycle 内の start 

    • stop

      public void stop()
      次で指定:
      インターフェース Lifecycle 内の stop 
      次で指定:
      インターフェース ManageableLifecycle 内の stop 

    • stop

      public void stop(RunnableSE callback)
      次で指定:
      インターフェース SmartLifecycle 内の stop 

    • destroy

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