クラス 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
コンストラクターのサマリー
コンストラクター コンストラクター 説明 SimpleConnection(com.rabbitmq.client.Connection delegate, int closeTimeout)
メソッドのサマリー
すべてのメソッド インスタンスメソッド 具象メソッド 修飾子と型 メソッド 説明 void
addBlockedListener(com.rabbitmq.client.BlockedListener listener)
BlockedListener
を追加します。void
close()
AMQP.REPLY_SUCCESS
クローズコードとメッセージ "OK" を使用して、この接続とそのすべてのチャネルを閉じます。com.rabbitmq.client.Channel
createChannel(boolean transactional)
内部的に割り当てられたチャネル番号を使用して、新しいチャネルを作成します。InetAddressSE
getAddress()
com.rabbitmq.client.Connection
getDelegate()
基礎となる RabbitMQ 接続を返します。InetAddressSE
getLocalAddress()
int
getLocalPort()
int
getPort()
boolean
isOpen()
接続が開いている場合は true。boolean
removeBlockedListener(com.rabbitmq.client.BlockedListener listener)
BlockedListener
を削除します。StringSE
toString()
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSE
インターフェース org.springframework.amqp.rabbit.connection.Connection から継承されたメソッド
closeThreadChannel
メソッドの詳細
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
- 戻り値:
- 接続。