インターフェース 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 接続を作成します。
    @Nullable com.rabbitmq.client.Channel
    getChannel(RabbitResourceHolder holder)
    指定された RabbitResourceHolder から適切なチャネルを取得します。
    @Nullable Connection
    getConnection(RabbitResourceHolder holder)
    指定された RabbitResourceHolder から適切な接続をフェッチします。
    boolean
    synchedLocalTransactionAllowed()
    Spring 管理トランザクション (たとえば、メイントランザクションが特定の DataSource 用の JDBC ベースのトランザクションである場合) と同期されるローカル RabbitMQ トランザクションを許可するかどうかを返します。メイントランザクションの直後に RabbitMQ トランザクションがコミットされます。

  • メソッドの詳細

    • getChannel

      @Nullable com.rabbitmq.client.Channel getChannel(RabbitResourceHolder holder)
      指定された RabbitResourceHolder から適切なチャネルを取得します。
      パラメーター:
      holder - RabbitResourceHolder
      戻り値:
      所有者から取得した適切なチャネル、または見つからない場合は null 

    • getConnection

      @Nullable 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 メソッドによってスローされた場合

    • synchedLocalTransactionAllowed

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