メソッドの詳細

• isChannelTransactional

  public static boolean isChannelTransactional​(com.rabbitmq.client.Channel channel,
                                               ConnectionFactory connectionFactory)

  指定された RabbitMQ チャネルがトランザクション対応であるかどうか、つまり、Spring のトランザクション機能によって現在のスレッドにバインドされているかどうかを判断します。

  パラメーター:

  channel - 確認する RabbitMQ チャネル

  connectionFactory - Channel の元となった RabbitMQ ConnectionFactory

  戻り値:

  チャネルがトランザクションかどうか

• getTransactionalResourceHolder

  public static RabbitResourceHolder getTransactionalResourceHolder​(ConnectionFactory connectionFactory,
                                                                    boolean synchedLocalTransactionAllowed)

  現在のトランザクションと同期されている RabbitMQ チャネルを取得します (存在する場合)。

  パラメーター:

  connectionFactory - チャネルを取得するための ConnectionFactory

  synchedLocalTransactionAllowed - Spring 管理のトランザクション (たとえば、メイントランザクションが特定の DataSource 用の JDBC ベースのトランザクションである場合) と同期されるローカル RabbitMQ トランザクションを許可するかどうか。RabbitMQ トランザクションはメイントランザクションの直後にコミットされます。許可されていない場合、指定された ConnectionFactory はカバーでトランザクションの登録を処理する必要があります。

  戻り値:

  トランザクションチャネル、または見つからない場合は null 

• getTransactionalResourceHolder

  public static RabbitResourceHolder getTransactionalResourceHolder​(ConnectionFactory connectionFactory,
                                                                    boolean synchedLocalTransactionAllowed,
                                                                    boolean publisherConnectionIfPossible)

  現在のトランザクションと同期されている RabbitMQ チャネルを取得します (存在する場合)。

  パラメーター:

  connectionFactory - チャネルを取得するための ConnectionFactory

  synchedLocalTransactionAllowed - Spring 管理のトランザクション (たとえば、メイントランザクションが特定の DataSource 用の JDBC ベースのトランザクションである場合) と同期されるローカル RabbitMQ トランザクションを許可するかどうか。RabbitMQ トランザクションはメイントランザクションの直後にコミットされます。許可されていない場合、指定された ConnectionFactory はカバーでトランザクションの登録を処理する必要があります。

  publisherConnectionIfPossible - 可能であれば、別のパブリッシャー接続から接続を取得します。

  戻り値:

  トランザクションチャネル、または見つからない場合は null 

• releaseResources

  public static void releaseResources​(@Nullable
                                      RabbitResourceHolder resourceHolder)

• bindResourceToTransaction

  public static RabbitResourceHolder bindResourceToTransaction​(RabbitResourceHolder resourceHolder,
                                                               ConnectionFactory connectionFactory,
                                                               boolean synched)

• enableAfterCompletionFailureCapture

  public static void enableAfterCompletionFailureCapture​(boolean enable)

  トランザクション同期の使用時に AfterCompletionFailedException のキャプチャーを有効にするには、このメソッドを呼び出します。例外は ThreadLocalSE に格納され、トランザクションの補完後に checkAfterCompletion() を呼び出してクリアする必要があります。

  パラメーター:

  enable - キャプチャーを有効にする場合は true。

• checkAfterCompletion

  public static void checkAfterCompletion()

  トランザクション同期を使用する場合、トランザクションのコミット後にこのメソッドを呼び出して、RabbitMQ トランザクションがコミットされたことを確認します。

  例外:

  AfterCompletionFailedException - 同期に失敗した場合。

  導入:

  2.3.10

• registerDeliveryTag

  public static void registerDeliveryTag​(ConnectionFactory connectionFactory,
                                         com.rabbitmq.client.Channel channel,
                                         LongSE tag)

• createConnection

  public static Connection createConnection​(ConnectionFactory connectionFactory,
                                            boolean publisherConnectionIfPossible)

  この接続ファクトリおよび / またはそのパブリッシャーファクトリとの接続を作成します。

  パラメーター:

  connectionFactory - 接続ファクトリ。

  publisherConnectionIfPossible - パブリッシャーファクトリが存在する場合、それを使用する場合は true。

  戻り値:

  接続。

  導入:

  2.0.2