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

クラス SimpleConnection

java.lang.ObjectSE
org.springframework.amqp.rabbit.connection.SimpleConnection
実装されたすべてのインターフェース:
com.rabbitmq.client.impl.NetworkConnection、AutoCloseableSE、Connection
public class SimpleConnection extends ObjectSE implements Connection, com.rabbitmq.client.impl.NetworkConnection
単に接続。
導入:
1.0
作成者:
Dave Syer, Gary Russell, Artem Bilan, Salk Lee

  • コンストラクターの詳細

    • SimpleConnection

      public SimpleConnection(com.rabbitmq.client.Connection delegate, int closeTimeout)

    • SimpleConnection

      public SimpleConnection(com.rabbitmq.client.Connection delegate, int closeTimeout, @Nullable BackOffExecution backOffExecution)
      BackOffExecution 引数を使用してインスタンスを構築します。
      パラメーター:
      delegate - 委譲接続
      closeTimeout - 物理的に閉じたタイムアウトの時間
      backOffExecution - backOffExecution は null 可能
      導入:
      3.1.3

  • メソッドの詳細

    • createChannel

      public com.rabbitmq.client.Channel createChannel(boolean transactional)
      インターフェースからコピーされた説明: Connection
      内部的に割り当てられたチャネル番号を使用して、新しいチャネルを作成します。
      次で指定:
      インターフェース Connection の createChannel 
      パラメーター:
      transactional - チャネルがトランザクションをサポートする必要がある場合は true
      戻り値:
      新しいチャネル記述子、または何も利用できない場合は null

    • close

      public void close()
      インターフェースからコピーされた説明: Connection
      AMQP.REPLY_SUCCESS クローズコードとメッセージ "OK" を使用して、この接続とそのすべてのチャネルを閉じます。すべてのクローズ操作が完了するまで待機します。
      次で指定:
      インターフェース AutoCloseableSE の close 
      次で指定:
      インターフェース Connection の close 

    • isOpen

      public boolean isOpen()
      接続が開いている場合は true。
      次で指定:
      インターフェース Connection の isOpen 
      戻り値:
      接続が開いている場合は true
      例外:
      AutoRecoverConnectionNotCurrentlyOpenException - 接続が AutorecoveringConnection で、現在閉じられている場合。これは、CachingConnectionFactory がこの接続を破棄して新しい接続を開くのを防ぐために必要です。その場合、「古い」接続は最終的に回復され、孤立します。また、それに属するコンシューマーも回復される可能性があり、ブローカーはそれらにメッセージを配信します。これらのメッセージを処理するために実際に実行されているコードがない場合 ( SimpleMessageListenerContainer を使用している場合)。実際に接続を閉じた場合 (例: CachingConnectionFactory.resetConnection() 経由)、これは false を返します。

    • getLocalPort

      public int getLocalPort()
      次で指定:
      インターフェース Connection の getLocalPort 
      次で指定:
      インターフェース com.rabbitmq.client.impl.NetworkConnection の getLocalPort 
      戻り値:
      基になる接続がサポートしている場合は、ローカルポート。

    • addBlockedListener

      public void addBlockedListener(com.rabbitmq.client.BlockedListener listener)
      インターフェースからコピーされた説明: Connection
      BlockedListener を追加します。
      次で指定:
      インターフェース Connection の addBlockedListener 
      パラメーター:
      listener - 追加するリスナー
      関連事項:
      • Connection.addBlockedListener(BlockedListener)

    • removeBlockedListener

      public boolean removeBlockedListener(com.rabbitmq.client.BlockedListener listener)
      インターフェースからコピーされた説明: Connection
      BlockedListener を削除します。
      次で指定:
      インターフェース Connection の removeBlockedListener 
      パラメーター:
      listener - 削除するリスナー
      戻り値:
      リスナーが見つかって削除された場合は true、それ以外の場合は false 
      関連事項:
      • Connection.removeBlockedListener(BlockedListener)

    • getLocalAddress

      public InetAddressSE getLocalAddress()
      次で指定:
      インターフェース com.rabbitmq.client.impl.NetworkConnection の getLocalAddress 

    • getAddress

      public InetAddressSE getAddress()
      次で指定:
      インターフェース com.rabbitmq.client.impl.NetworkConnection の getAddress 

    • getPort

      public int getPort()
      次で指定:
      インターフェース com.rabbitmq.client.impl.NetworkConnection の getPort 

    • getDelegate

      public com.rabbitmq.client.Connection getDelegate()
      インターフェースからコピーされた説明: Connection
      基礎となる RabbitMQ 接続を返します。
      次で指定:
      インターフェース Connection の getDelegate 
      戻り値:
      接続。

    • toString

      public StringSE toString()
      オーバーライド:
      クラス ObjectSE の toString