クラス PooledChannelConnectionFactory

java.lang.ObjectSE
org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
org.springframework.amqp.rabbit.connection.PooledChannelConnectionFactory
実装されているすべてのインターフェース:
com.rabbitmq.client.ShutdownListener、EventListenerSE、ConnectionFactory、Aware、BeanNameAware、DisposableBean、ApplicationContextAware、ApplicationEventPublisherAware、ApplicationListener<ContextClosedEvent>、Lifecycle、Phased、SmartLifecycle
public class PooledChannelConnectionFactory extends AbstractConnectionFactory implements com.rabbitmq.client.ShutdownListener, SmartLifecycle
Apache Pool2 GenericObjectPool (トランザクションチャネル用と非トランザクションチャネル用) を使用してチャネルをキャッシュする非常にシンプルな接続ファクトリ。プールにはデフォルトの構成がありますが、コールバックを使用して構成できます。
導入:
2.3
作成者:
Gary Russell, Leonardo Ferreira, Christian Tzolov, Ngoc Nhan

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

    • PooledChannelConnectionFactory

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

  • メソッドの詳細

    • setPublisherConnectionFactory

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

    • setPoolConfigurer

      public void setPoolConfigurer(BiConsumerSE<org.apache.commons.pool2.impl.GenericObjectPool<com.rabbitmq.client.Channel>, BooleanSE> poolConfigurer)
      コンシューマーを追加して、オブジェクトプールを構成します。トランザクションプールで呼び出された場合、2 番目の引数は true です。
      パラメーター:
      poolConfigurer - コンフィギュレーター。

    • isSimplePublisherConfirms

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

    • setSimplePublisherConfirms

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

    • addConnectionListener

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

    • 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 

    • createConnection

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

    • resetConnection

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

    • destroy

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