クラス PooledChannelConnectionFactory

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

      • PooledChannelConnectionFactory

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

      • 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 を返します。
        次で指定:
        インターフェース ConnectionFactoryisSimplePublisherConfirms 
        戻り値:
        simplePublisherConfirms
      • setSimplePublisherConfirms

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

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