パッケージ org.springframework.integration.amqp.channel

クラス 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、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