メソッドの詳細

• createChannel

  com.rabbitmq.client.Channel createChannel​(boolean transactional)
                                     throws AmqpException

  内部的に割り当てられたチャネル番号を使用して、新しいチャネルを作成します。

  パラメーター:

  transactional - チャネルがトランザクションをサポートする必要がある場合は true

  戻り値:

  新しいチャネル記述子、または何も利用できない場合は null

  例外:

  AmqpException - I/O の問題が発生した場合

• close

  void close()
      throws AmqpException

  AMQP.REPLY_SUCCESS クローズコードとメッセージ "OK" を使用して、この接続とそのすべてのチャネルを閉じます。すべてのクローズ操作が完了するまで待機します。

  次で指定:

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

  例外:

  AmqpException - I/O の問題が発生した場合

• isOpen

  boolean isOpen()

  接続のステータスを示すフラグ。

  戻り値:

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

• getLocalPort

  int getLocalPort()

  戻り値:

  基になる接続がサポートしている場合は、ローカルポート。

• addBlockedListener

  void addBlockedListener​(com.rabbitmq.client.BlockedListener listener)

  BlockedListener を追加します。

  パラメーター:

  listener - 追加するリスナー

  導入:

  2.0

  関連事項:

  Connection.addBlockedListener(BlockedListener)

• removeBlockedListener

  boolean removeBlockedListener​(com.rabbitmq.client.BlockedListener listener)

  BlockedListener を削除します。

  パラメーター:

  listener - 削除するリスナー

  戻り値:

  リスナーが見つかって削除された場合は true、それ以外の場合は false 

  導入:

  2.0

  関連事項:

  Connection.removeBlockedListener(BlockedListener)

• getDelegate

  @Nullable
  default com.rabbitmq.client.Connection getDelegate()

  基礎となる RabbitMQ 接続を返します。

  戻り値:

  接続。

• closeThreadChannel

  default void closeThreadChannel()

  現在のスレッドに関連付けられているチャネルを閉じます。