インターフェース AmqpAdmin

メソッドの詳細

• 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。

• getManualDeclarables

  @DeprecatedSE default MapSE<StringSE,Declarable> getManualDeclarables()

  使用すべきではありません。

  getManualDeclarableSet() を推奨。

  手動で宣言された AMQP オブジェクトを返します。

  戻り値:

  手動で宣言された AMQP オブジェクト。

  導入:

  2.4.13

• getManualDeclarableSet

  default SetSE<Declarable> getManualDeclarableSet()

  手動で宣言された AMQP オブジェクトを返します。

  戻り値:

  手動で宣言された AMQP オブジェクト。

  導入:

  2.4.15

• initialize

  default void initialize()

  管理者を初期化します。

  導入:

  2.1