クラス 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)インスタンスを構築します。
方法の概要
すべてのメソッド インスタンスメソッド 具象メソッド 修飾子と型 メソッド 説明 voidaddConnectionListener(ConnectionListener listener)ConnectioncreateConnection()voiddestroy()booleanisSimplePublisherConfirms()シンプルな発行者の確認が有効になっている場合は true を返します。voidresetConnection()接続を閉じる。voidsetPoolConfigurer(BiConsumerSE<org.apache.commons.pool2.impl.GenericObjectPool<com.rabbitmq.client.Channel>,BooleanSE> poolConfigurer)コンシューマーを追加して、オブジェクトプールを構成します。voidsetPublisherConnectionFactory(AbstractConnectionFactory publisherConnectionFactory)カスタムパブリッシャー接続ファクトリを設定します。型はこのファクトリと同じである必要はありません。voidsetSimplePublisherConfirms(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