コンストラクターの詳細

• SimpleConnection

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

メソッドの詳細

• 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 内の closeSE 

  次で指定:

  インターフェース Connection 内の close 

• isOpen

  public boolean isOpen()

  接続が開いている場合は true。

  次で指定:

  インターフェース Connection 内の isOpen 

  戻り値:

  接続が開いている場合は true

  例外:

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

• getLocalPort

  public int getLocalPort()

  次で指定:

  インターフェース com.rabbitmq.client.impl.NetworkConnection 内の getLocalPort 

  次で指定:

  インターフェース Connection 内の 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 の toStringSE