クラス PublishSubscribeAmqpChannel

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.channel.AbstractMessageChannel
org.springframework.integration.amqp.channel.AbstractAmqpChannel
org.springframework.integration.amqp.channel.PublishSubscribeAmqpChannel
実装済みのインターフェース一覧:
ConnectionListener, Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, BroadcastCapableChannel, ComponentSourceAware, ExpressionCapable, IntegrationPattern, NamedComponent, IntegrationManagement, ManageableLifecycle, ManageableSmartLifecycle, TrackableComponent, MessageChannel, SubscribableChannel, InterceptableChannel
public class PublishSubscribeAmqpChannel extends AbstractAmqpChannel implements BroadcastCapableChannel
FanoutExchange に基づく pub-sub セマンティクスの AbstractSubscribableAmqpChannel 拡張。
導入:
2.1
作成者:
Mark Fisher, Gary Russell, Artem Bilan

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

    • PublishSubscribeAmqpChannel

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

    • PublishSubscribeAmqpChannel

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

  • 方法の詳細

    • setExchange

      public void setExchange(FanoutExchange exchange)
      FanoutExchange インスタンスを構成します。これが指定されていない場合、FanoutExchange は暗黙的に宣言され、その名前は "si.fanout." で始まるチャネル名と同じになります。いずれの場合も、事実上匿名のキューが自動的に宣言されます。
      パラメーター:
      exchange - ファンアウト交換。

    • getExchangeName

      protected StringSE getExchangeName()
      クラスからコピーされた説明: AbstractAmqpChannel
      サブクラスはこのメソッドをオーバーライドして、Exchange 名を返す場合があります。デフォルトでは、メッセージは名前のない直接交換に送信されます。
      オーバーライド:
      クラス AbstractAmqpChannel の getExchangeName 
      戻り値:
      エクスチェンジ名。

    • obtainQueueName

      protected StringSE obtainQueueName(StringSE channelName)

    • createDispatcher

      protected AbstractDispatcher createDispatcher()

    • 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