クラス RabbitAccessor

java.lang.ObjectSE
org.springframework.amqp.rabbit.connection.RabbitAccessor
実装されているすべてのインターフェース:
InitializingBean
既知の直属サブクラス
ObservableListenerContainer, RabbitTemplate
public abstract class RabbitAccessor extends ObjectSE implements InitializingBean
作成者:
Mark Fisher, Dave Syer, Gary Russell, Artem Bilan

  • フィールドの詳細

    • logger

      protected final org.apache.commons.logging.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。

    • afterPropertiesSet

      public void afterPropertiesSet()
      次で指定:
      インターフェース InitializingBean の afterPropertiesSet 

    • createConnection

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

    • getConnection

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

    • getChannel

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

    • getTransactionalResourceHolder

      protected RabbitResourceHolder getTransactionalResourceHolder()

    • convertRabbitAccessException

      protected RuntimeExceptionSE convertRabbitAccessException(ExceptionSE ex)

    • obtainObservationRegistry

      protected void obtainObservationRegistry(@Nullable ApplicationContext appContext)

    • getObservationRegistry

      protected io.micrometer.observation.ObservationRegistry getObservationRegistry()