クラス 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)
インスタンスを構築します。
メソッドのサマリー
すべてのメソッド インスタンスメソッド 具象メソッド 修飾子と型 メソッド 説明 void
addConnectionListener(ConnectionListener listener)
void
closeThreadChannel()
このスレッドに関連付けられているチャネルがあれば、閉じます。Connection
createConnection()
void
destroy()
boolean
isSimplePublisherConfirms()
シンプルな発行者の確認が有効になっている場合は true を返します。ObjectSE
prepareSwitchContext()
このスレッドが所有するチャネルを別のスレッドに切り替える準備をするために呼び出します。void
resetConnection()
接続を閉じる。void
setPublisherConnectionFactory(AbstractConnectionFactory publisherConnectionFactory)
カスタムパブリッシャー接続ファクトリを設定します。型はこのファクトリと同じである必要はありません。void
setSimplePublisherConfirms(boolean simplePublisherConfirms)
簡単な発行者確認を有効にします。void
switchContext(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()