パッケージ org.springframework.amqp.core

インターフェース AmqpAdmin

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

    • メソッドの詳細

      • 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