public class PooledChannelConnectionFactory extends AbstractConnectionFactory implements com.rabbitmq.client.ShutdownListener
GenericObjectPool (トランザクションチャネル用と非トランザクションチャネル用) を使用してチャネルをキャッシュする非常にシンプルな接続ファクトリ。プールにはデフォルトの構成がありますが、コールバックを使用して構成できます。AbstractConnectionFactory.AddressShuffleModeDEFAULT_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) 簡単な発行者確認を有効にします。 |
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, toStringcloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEisPublisherConfirms, isPublisherReturnsforPayloadpublic PooledChannelConnectionFactory(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory)
rabbitConnectionFactory - rabbitmq 接続ファクトリ。public void setPublisherConnectionFactory(@Nullable AbstractConnectionFactory publisherConnectionFactory)
AbstractConnectionFactoryAbstractConnectionFactory の setPublisherConnectionFactory publisherConnectionFactory - ファクトリ。public void setPoolConfigurer(BiConsumerSE<org.apache.commons.pool2.impl.GenericObjectPool<com.rabbitmq.client.Channel>,BooleanSE> poolConfigurer)
poolConfigurer - コンフィギュレーター。public boolean isSimplePublisherConfirms()
ConnectionFactoryConnectionFactory 内の isSimplePublisherConfirms public void setSimplePublisherConfirms(boolean simplePublisherConfirms)
simplePublisherConfirms - 有効にする場合は true。public void addConnectionListener(ConnectionListener listener)
ConnectionFactory 内の addConnectionListener AbstractConnectionFactory の addConnectionListener public Connection createConnection() throws AmqpException
ConnectionFactory 内の createConnection AmqpExceptionpublic void resetConnection()
public void destroy()
DisposableBean 内の destroy AbstractConnectionFactory の destroy