インターフェース Connection
- すべてのスーパーインターフェース:
AutoCloseableSE
- すべての既知のサブインターフェース:
ConnectionProxy
- すべての既知の実装クラス:
SimpleConnection
- 作成者:
- Dave Syer, Gary Russell, Artem Bilan
メソッドのサマリー
修飾子と型メソッド説明void
addBlockedListener
(com.rabbitmq.client.BlockedListener listener) BlockedListener
を追加します。void
close()
AMQP.REPLY_SUCCESS
クローズコードとメッセージ "OK" を使用して、この接続とそのすべてのチャネルを閉じます。default void
現在のスレッドに関連付けられているチャネルを閉じます。com.rabbitmq.client.Channel
createChannel
(boolean transactional) 内部的に割り当てられたチャネル番号を使用して、新しいチャネルを作成します。default com.rabbitmq.client.Connection
基礎となる RabbitMQ 接続を返します。int
boolean
isOpen()
接続のステータスを示すフラグ。boolean
removeBlockedListener
(com.rabbitmq.client.BlockedListener listener) BlockedListener
を削除します。
メソッドの詳細
createChannel
内部的に割り当てられたチャネル番号を使用して、新しいチャネルを作成します。- パラメーター:
transactional
- チャネルがトランザクションをサポートする必要がある場合は true- 戻り値:
- 新しいチャネル記述子、または何も利用できない場合は null
- 例外:
AmqpException
- I/O の問題が発生した場合
close
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
基礎となる RabbitMQ 接続を返します。- 戻り値:
- 接続。
closeThreadChannel
default void closeThreadChannel()現在のスレッドに関連付けられているチャネルを閉じます。