インターフェース ConnectionFactoryUtils.ResourceFactory

含まれているクラス:
ConnectionFactoryUtils
public static interface ConnectionFactoryUtils.ResourceFactory
リソース作成用のコールバックインターフェース。doGetTransactionalChannel メソッドの引数として機能します。
作成者:
Mark Fisher, Dave Syer, Gary Russell, Artem Bilan

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    com.rabbitmq.client.Channel
    createChannel(Connection con)
    RabbitResourceHolder に登録するための新しい RabbitMQ セッションを作成します。
    Connection
    createConnection()
    RabbitResourceHolder に登録するための新しい RabbitMQ 接続を作成します。
    com.rabbitmq.client.Channel
    getChannel(RabbitResourceHolder holder)
    指定された RabbitResourceHolder から適切なチャネルを取得します。
    Connection
    getConnection(RabbitResourceHolder holder)
    指定された RabbitResourceHolder から適切な接続をフェッチします。
    boolean
    isSynchedLocalTransactionAllowed()
    Spring 管理トランザクション (たとえば、メイントランザクションが特定の DataSource 用の JDBC ベースのトランザクションである場合) と同期されるローカル RabbitMQ トランザクションを許可するかどうかを返します。メイントランザクションの直後に RabbitMQ トランザクションがコミットされます。

  • メソッドの詳細

    • 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 トランザクションの同期を許可するかどうか