インターフェース AmqpAdmin

すべての既知の実装クラス:
RabbitAdmin, RabbitAmqpAdmin
public interface AmqpAdmin
AMQP > 0.9 の移植可能な AMQP 管理操作の基本セットを指定します。
作成者:
Mark Pollack, Dave Syer, Gary Russell, Artem Bilan

  • メソッドの詳細

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

    • getManualDeclarableSet

      default SetSE<Declarable> getManualDeclarableSet()
      手動で宣言された AMQP オブジェクトを返します。
      戻り値:
      手動で宣言された AMQP オブジェクト。
      導入:
      2.4.15

    • initialize

      default void initialize()
      管理者を初期化します。
      導入:
      2.1