クラス RabbitAccessor

    • フィールドの詳細

      • logger

        protected final Log logger
        サブクラスで利用可能なロガー。
    • コンストラクターの詳細

      • RabbitAccessor

        public RabbitAccessor()
    • メソッドの詳細

      • isChannelTransacted

        public boolean isChannelTransacted()
      • setChannelTransacted

        public void setChannelTransacted​(boolean transactional)
        このコンポーネントによって作成されたチャネルがトランザクションになることを示すフラグ。
        パラメーター:
        transactional - 設定するフラグ値
      • setConnectionFactory

        public void setConnectionFactory​(ConnectionFactory connectionFactory)
        RabbitMQ Connections の取得に使用する ConnectionFactory を設定します。
        パラメーター:
        connectionFactory - 接続ファクトリ。
      • getConnectionFactory

        public ConnectionFactory getConnectionFactory()
        戻り値:
        このアクセサーが RabbitMQ Connections を取得するために使用する ConnectionFactory。
      • createConnection

        protected Connection createConnection()
        このテンプレートの ConnectionFactory とそのホストとポートの値を使用して、RabbitMQ 接続を作成します。
        戻り値:
        新しい RabbitMQ 接続
        関連事項:
        ConnectionFactory.createConnection()
      • getConnection

        @Nullable
        protected Connection getConnection​(RabbitResourceHolder holder)
        指定された RabbitResourceHolder から適切な接続をフェッチします。
        パラメーター:
        holder - RabbitResourceHolder
        戻り値:
        ホルダーからフェッチされた適切な接続、または見つからない場合は null 
      • getChannel

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