インターフェース ConnectionFactoryUtils.ResourceFactory

メソッドの詳細

• getChannel

  @Nullable com.rabbitmq.client.Channel getChannel(RabbitResourceHolder holder)

  指定された RabbitResourceHolder から適切なチャネルを取得します。

  パラメーター:

  holder - RabbitResourceHolder

  戻り値:

  所有者から取得した適切なチャネル、または見つからない場合は null 

• getConnection

  Connection getConnection(RabbitResourceHolder holder)

  指定された RabbitResourceHolder から適切な接続をフェッチします。

  パラメーター:

  holder - RabbitResourceHolder

  戻り値:

  ホルダーからフェッチされた適切な接続、または見つからない場合は null 

• createConnection

  Connection createConnection() throws IOExceptionSE

  RabbitResourceHolder に登録するための新しい RabbitMQ 接続を作成します。

  戻り値:

  新しい RabbitMQ 接続

  例外:

  IOExceptionSE - RabbitMQ API メソッドによってスローされた場合

• createChannel

  com.rabbitmq.client.Channel createChannel(Connection con) throws IOExceptionSE

  RabbitResourceHolder に登録するための新しい RabbitMQ セッションを作成します。

  パラメーター:

  con - チャネルを作成するための RabbitMQ 接続

  戻り値:

  新しい RabbitMQ チャネル

  例外:

  IOExceptionSE - RabbitMQ API メソッドによってスローされた場合

• isSynchedLocalTransactionAllowed

  boolean isSynchedLocalTransactionAllowed()

  Spring 管理トランザクション (たとえば、メイントランザクションが特定の DataSource 用の JDBC ベースのトランザクションである場合) と同期されるローカル RabbitMQ トランザクションを許可するかどうかを返します。メイントランザクションの直後に RabbitMQ トランザクションがコミットされます。

  戻り値:

  ローカル RabbitMQ トランザクションの同期を許可するかどうか