クラス ThreadChannelConnectionFactory

java.lang.ObjectSE
org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
org.springframework.amqp.rabbit.connection.ThreadChannelConnectionFactory
実装されているすべてのインターフェース:
com.rabbitmq.client.ShutdownListener、EventListenerSE、ConnectionFactory、Aware、BeanNameAware、DisposableBean、ApplicationContextAware、ApplicationEventPublisherAware、ApplicationListener<ContextClosedEvent>、Lifecycle、Phased、SmartLifecycle
public class ThreadChannelConnectionFactory extends AbstractConnectionFactory implements com.rabbitmq.client.ShutdownListener, SmartLifecycle
スレッドごとにチャネルをキャッシュする非常に単純な接続ファクトリ。ユーザーは、closeThreadChannel() を呼び出してスレッドのチャネルを解放する必要があります。
導入:
2.3
作成者:
Gary Russell, Leonardo Ferreira, Christian Tzolov, Ngoc Nhan

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

    • ThreadChannelConnectionFactory

      public ThreadChannelConnectionFactory(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory)
      インスタンスを構築します。
      パラメーター:
      rabbitConnectionFactory - rabbitmq 接続ファクトリ。

  • メソッドの詳細

    • setPublisherConnectionFactory

      public void setPublisherConnectionFactory(@Nullable AbstractConnectionFactory publisherConnectionFactory)
      クラスからコピーされた説明: AbstractConnectionFactory
      カスタムパブリッシャー接続ファクトリを設定します。型はこのファクトリと同じである必要はありません。
      オーバーライド:
      クラス AbstractConnectionFactory の setPublisherConnectionFactory 
      パラメーター:
      publisherConnectionFactory - ファクトリ。

    • isSimplePublisherConfirms

      public boolean isSimplePublisherConfirms()
      インターフェースからコピーされた説明: ConnectionFactory
      シンプルな発行者の確認が有効になっている場合は true を返します。
      次で指定:
      インターフェース ConnectionFactory の isSimplePublisherConfirms 
      戻り値:
      simplePublisherConfirms

    • setSimplePublisherConfirms

      public void setSimplePublisherConfirms(boolean simplePublisherConfirms)
      簡単な発行者確認を有効にします。
      パラメーター:
      simplePublisherConfirms - 有効にする場合は true。

    • getPhase

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

    • start

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

    • stop

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

    • isRunning

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

    • addConnectionListener

      public void addConnectionListener(ConnectionListener listener)
      次で指定:
      インターフェース ConnectionFactory の addConnectionListener 
      オーバーライド:
      クラス AbstractConnectionFactory の addConnectionListener 

    • createConnection

      public Connection createConnection() throws AmqpException
      次で指定:
      インターフェース ConnectionFactory の createConnection 
      例外:
      AmqpException

    • closeThreadChannel

      public void closeThreadChannel()
      このスレッドに関連付けられているチャネルがあれば、閉じます。

    • resetConnection

      public void resetConnection()
      接続を閉じます。これは、進行中の操作に影響を与えます。このメソッドが戻った後、必要に応じて新しい接続が作成されます。これは、セカンダリブローカにフェイルオーバーした後、プライマリブローカへの再接続を強制するために使用される場合があります。
      次で指定:
      インターフェース ConnectionFactory の resetConnection 

    • destroy

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

    • prepareSwitchContext

      @Nullable public ObjectSE prepareSwitchContext()
      このスレッドが所有するチャネルを別のスレッドに切り替える準備をするために呼び出します。
      戻り値:
      切り替えるコンテキストを表す不透明なオブジェクト。このスレッドにチャネルが割り当てられていないか、開いているチャネルがない場合は、null が返されます。
      導入:
      2.3.7
      関連事項:

    • switchContext

      public void switchContext(@Nullable ObjectSE toSwitch)
      そのスレッドが prepareSwitchContext() を呼び出した後、別のスレッドのチャネルの所有権を取得します。
      パラメーター:
      toSwitch - prepareSwitchContext() によって返されるコンテキスト。
      導入:
      2.3.7
      関連事項: