パッケージ org.springframework.amqp.rabbit.connection

インターフェース ConnectionFactoryUtils.ResourceFactory

  • 含まれているクラス:
    ConnectionFactoryUtils
    public static interface ConnectionFactoryUtils.ResourceFactory
    リソース作成用のコールバックインターフェース。doGetTransactionalChannel メソッドの引数として機能します。

    • メソッドのサマリー

      すべてのメソッド   インスタンスメソッド   抽象メソッド  
      修飾子と型 メソッド 説明
      com.rabbitmq.client.ChannelcreateChannel​(Connection con)
      RabbitResourceHolder に登録するための新しい RabbitMQ セッションを作成します。
      ConnectioncreateConnection()
      RabbitResourceHolder に登録するための新しい RabbitMQ 接続を作成します。
      com.rabbitmq.client.ChannelgetChannel​(RabbitResourceHolder holder)
      指定された RabbitResourceHolder から適切なチャネルを取得します。
      ConnectiongetConnection​(RabbitResourceHolder holder)
      指定された RabbitResourceHolder から適切な接続をフェッチします。
      booleanisSynchedLocalTransactionAllowed()
      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 トランザクションの同期を許可するかどうか