クラス ThreadChannelConnectionFactory
- java.lang.ObjectSE
-
- org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
-
- org.springframework.amqp.rabbit.connection.ThreadChannelConnectionFactory
- 実装されているすべてのインターフェース:
com.rabbitmq.client.ShutdownListener、EventListenerSE、ConnectionFactory、Aware、BeanNameAware、DisposableBean、ApplicationContextAware、ApplicationEventPublisherAware、ApplicationListener<ContextClosedEvent>
public class ThreadChannelConnectionFactory extends AbstractConnectionFactory implements com.rabbitmq.client.ShutdownListener
スレッドごとにチャネルをキャッシュする非常に単純な接続ファクトリ。ユーザーは、closeThreadChannel()を呼び出してスレッドのチャネルを解放する必要があります。- 導入:
- 2.3
- 作成者:
- Gary Russell
ネストされたクラスの要約
クラス org.springframework.amqp.rabbit.connection.AbstractConnectionFactory から継承されたネストクラス / インターフェース
AbstractConnectionFactory.AddressShuffleMode
フィールドのサマリー
クラス org.springframework.amqp.rabbit.connection.AbstractConnectionFactory から継承されたフィールド
DEFAULT_CLOSE_TIMEOUT, logger
コンストラクターの概要
コンストラクター コンストラクター 説明 ThreadChannelConnectionFactory(com.rabbitmq.client.ConnectionFactory rabbitConnectionFactory)インスタンスを構築します。
メソッドのサマリー
すべてのメソッド インスタンスメソッド 具象メソッド 修飾子と型 メソッド 説明 voidaddConnectionListener(ConnectionListener listener)voidcloseThreadChannel()このスレッドに関連付けられているチャネルがあれば、閉じます。ConnectioncreateConnection()voiddestroy()booleanisSimplePublisherConfirms()シンプルな発行者の確認が有効になっている場合は true を返します。ObjectSEprepareSwitchContext()このスレッドが所有するチャネルを別のスレッドに切り替える準備をするために呼び出します。voidresetConnection()接続を閉じる。voidsetPublisherConnectionFactory(AbstractConnectionFactory publisherConnectionFactory)カスタムパブリッシャー接続ファクトリを設定します。型はこのファクトリと同じである必要はありません。voidsetSimplePublisherConfirms(boolean simplePublisherConfirms)簡単な発行者確認を有効にします。voidswitchContext(ObjectSE toSwitch)そのスレッドがprepareSwitchContext()を呼び出した後、別のスレッドのチャネルの所有権を取得します。クラス 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- ファクトリ。
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
closeThreadChannel
public void closeThreadChannel()
このスレッドに関連付けられているチャネルがあれば、閉じます。
resetConnection
public void resetConnection()
接続を閉じます。これは、進行中の操作に影響を与えます。このメソッドが戻った後、必要に応じて新しい接続が作成されます。これは、セカンダリブローカにフェイルオーバーした後、プライマリブローカへの再接続を強制するために使用される場合があります。
destroy
public void destroy()
- 次で指定:
- インターフェース
DisposableBeanのdestroy - オーバーライド:
- クラス
AbstractConnectionFactoryのdestroy
prepareSwitchContext
@Nullable public ObjectSE prepareSwitchContext()
このスレッドが所有するチャネルを別のスレッドに切り替える準備をするために呼び出します。- 戻り値:
- 切り替えるコンテキストを表す不透明なオブジェクト。このスレッドにチャネルが割り当てられていないか、開いているチャネルがない場合は、null が返されます。
- 導入:
- 2.3.7
- 関連事項:
switchContext(Object)
switchContext
public void switchContext(@Nullable ObjectSE toSwitch)
そのスレッドがprepareSwitchContext()を呼び出した後、別のスレッドのチャネルの所有権を取得します。- パラメーター:
toSwitch-prepareSwitchContext()によって返されるコンテキスト。- 導入:
- 2.3.7
- 関連事項:
prepareSwitchContext()