クラス 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>
public class PooledChannelConnectionFactory extends AbstractConnectionFactory implements com.rabbitmq.client.ShutdownListener
Apache Pool2GenericObjectPool
(トランザクションチャネル用と非トランザクションチャネル用) を使用してチャネルをキャッシュする非常にシンプルな接続ファクトリ。プールにはデフォルトの構成がありますが、コールバックを使用して構成できます。- 導入:
- 2.3
- 作成者:
- Gary Russell
ネストされたクラスのサマリー
クラス org.springframework.amqp.rabbit.connection.AbstractConnectionFactory から継承されたネストクラス / インターフェース
AbstractConnectionFactory.AddressShuffleMode
フィールドサマリー
クラス org.springframework.amqp.rabbit.connection.AbstractConnectionFactory から継承されたフィールド
DEFAULT_CLOSE_TIMEOUT, logger
コンストラクターのサマリー
コンストラクター コンストラクター 説明 PooledChannelConnectionFactory(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory)
インスタンスを構築します。
メソッドのサマリー
すべてのメソッド インスタンスメソッド 具象メソッド 修飾子と型 メソッド 説明 void
addConnectionListener(ConnectionListener listener)
Connection
createConnection()
void
destroy()
boolean
isSimplePublisherConfirms()
シンプルな発行者の確認が有効になっている場合は true を返します。void
resetConnection()
接続を閉じる。void
setPoolConfigurer(BiConsumerSE<org.apache.commons.pool2.impl.GenericObjectPool<com.rabbitmq.client.Channel>,BooleanSE> poolConfigurer)
コンシューマーを追加して、オブジェクトプールを構成します。void
setPublisherConnectionFactory(AbstractConnectionFactory publisherConnectionFactory)
カスタムパブリッシャー接続ファクトリを設定します。型はこのファクトリと同じである必要はありません。void
setSimplePublisherConfirms(boolean simplePublisherConfirms)
簡単な発行者確認を有効にします。クラス org.springframework.amqp.rabbit.connection.AbstractConnectionFactory から継承されたメソッド
addChannelListener, clearConnectionListeners, createBareConnection, doSetPublisherConnectionFactory, getApplicationContext, getApplicationEventPublisher, getBeanName, getChannelListener, getCloseTimeout, getConnectionListener, getConnectionNameStrategy, getContextStopped, getDefaultHostName, getExecutorService, getHost, getPort, getPublisherConnectionFactory, getRabbitConnectionFactory, getUsername, getVirtualHost, hasPublisherConnectionFactory, onApplicationEvent, removeConnectionListener, setAddresses, setAddressResolver, setAddressShuffleMode, setApplicationContext, setApplicationEventPublisher, setBeanName, setChannelListeners, setCloseExceptionLogger, setCloseTimeout, setConnectionListeners, setConnectionNameStrategy, setConnectionThreadFactory, setConnectionTimeout, setExecutor, setHost, setPassword, setPort, setRecoveryListener, setRequestedHeartBeat, setShuffleAddresses, setUri, setUri, setUsername, setVirtualHost, shutdownCompleted, toString
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSE
インターフェース org.springframework.amqp.rabbit.connection.ConnectionFactory から継承されたメソッド
isPublisherConfirms, isPublisherReturns
メソッドの詳細
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
createConnection
public Connection createConnection() throws AmqpException
- 次で指定:
- インターフェース
ConnectionFactory
のcreateConnection
- 例外:
AmqpException
resetConnection
public void resetConnection()
接続を閉じます。これは、進行中の操作に影響を与えます。このメソッドが戻った後、必要に応じて新しい接続が作成されます。これは、セカンダリブローカにフェイルオーバーした後、プライマリブローカへの再接続を強制するために使用される場合があります。
destroy
public void destroy()
- 次で指定:
- インターフェース
DisposableBean
のdestroy
- オーバーライド:
- クラス
AbstractConnectionFactory
のdestroy