インターフェース AmqpAdmin
- すべての既知の実装クラス:
RabbitAdmin
public interface AmqpAdmin
AMQP > 0.9 の移植可能な AMQP 管理操作の基本セットを指定します。- 作成者:
- Mark Pollack, Dave Syer, Gary Russell
メソッドのサマリー
すべてのメソッド インスタンスメソッド 抽象メソッド デフォルトメソッド 修飾子と型 メソッド 説明 void
declareBinding(Binding binding)
交換へのキューのバインディングを宣言します。void
declareExchange(Exchange exchange)
交換を宣言します。Queue
declareQueue()
名前が自動的に付けられるキューを宣言します。StringSE
declareQueue(Queue queue)
指定されたキューを宣言します。boolean
deleteExchange(StringSE exchangeName)
交換を削除します。boolean
deleteQueue(StringSE queueName)
使用中かメッセージがあるかに関係なく、キューを削除します。void
deleteQueue(StringSE queueName, boolean unused, boolean empty)
キューを削除します。QueueInformation
getQueueInfo(StringSE queueName)
キューが存在する場合は、キューに関する情報を返します。PropertiesSE
getQueueProperties(StringSE queueName)
キューが存在する場合、プロパティの実装固有の Map を返します。default void
initialize()
管理者を初期化します。int
purgeQueue(StringSE queueName)
指定されたキューの内容をパージします。void
purgeQueue(StringSE queueName, boolean noWait)
指定されたキューの内容をパージします。void
removeBinding(Binding binding)
エクスチェンジへのキューのバインドを削除します。
メソッドの詳細
declareExchange
void declareExchange(Exchange exchange)
交換を宣言します。- パラメーター:
exchange
- 宣言する交換。
deleteExchange
boolean deleteExchange(StringSE exchangeName)
交換を削除します。実装固有の動作については、実装固有のサブクラスを参照してください。たとえば、RabbitMQ の場合、使用中かどうかに関係なく交換が削除されます。- パラメーター:
exchangeName
- 取引所の名前- 戻り値:
- 交換が存在し、削除された場合は true
declareQueue
@Nullable Queue declareQueue()
名前が自動的に付けられるキューを宣言します。これは、exclusive = true、autoDelete = true、durable = false で作成されます。- 戻り値:
- 待ち行列。
declareQueue
@Nullable StringSE declareQueue(Queue queue)
指定されたキューを宣言します。- パラメーター:
queue
- 宣言するキュー。- 戻り値:
- キューの名前。
deleteQueue
boolean deleteQueue(StringSE queueName)
使用中かメッセージがあるかに関係なく、キューを削除します。- パラメーター:
queueName
- キューの名前。- 戻り値:
- キューが存在し、削除された場合は true。
deleteQueue
void deleteQueue(StringSE queueName, boolean unused, boolean empty)
キューを削除します。- パラメーター:
queueName
- キューの名前。unused
- 使用されていない場合にのみキューを削除する必要がある場合は true。empty
- 空の場合にのみキューを削除する場合は true。
purgeQueue
void purgeQueue(StringSE queueName, boolean noWait)
指定されたキューの内容をパージします。- パラメーター:
queueName
- キューの名前。noWait
- パージの補完を待たない場合は true。
purgeQueue
int purgeQueue(StringSE queueName)
指定されたキューの内容をパージします。- パラメーター:
queueName
- キューの名前。- 戻り値:
- パージされたメッセージの数。
- 導入:
- 2.1
declareBinding
void declareBinding(Binding binding)
交換へのキューのバインディングを宣言します。- パラメーター:
binding
- 宣言するバインディングの説明。
removeBinding
void removeBinding(Binding binding)
エクスチェンジへのキューのバインドを削除します。unbindQueue/removeBinding は仕様の 0.9 まで導入されていないことに注意してください。- パラメーター:
binding
- 削除するバインディングの説明。
getQueueProperties
@Nullable PropertiesSE getQueueProperties(StringSE queueName)
キューが存在する場合、プロパティの実装固有の Map を返します。- パラメーター:
queueName
- キューの名前。- 戻り値:
- プロパティ、またはキューが存在しない場合は null。
getQueueInfo
@Nullable QueueInformation getQueueInfo(StringSE queueName)
キューが存在する場合は、キューに関する情報を返します。- パラメーター:
queueName
- キューの名前。- 戻り値:
- 情報、またはキューが存在しない場合は null。
initialize
default void initialize()
管理者を初期化します。- 導入:
- 2.1