クラス RabbitAmqpAdmin

メソッドの詳細

• setApplicationContext

  public void setApplicationContext(ApplicationContext applicationContext)

  次で指定:

  インターフェース ApplicationContextAware の setApplicationContext 

• setApplicationEventPublisher

  public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)

  次で指定:

  インターフェース ApplicationEventPublisherAware の setApplicationEventPublisher 

• setBeanName

  public void setBeanName(StringSE name)

  次で指定:

  インターフェース BeanNameAware の setBeanName 

• setIgnoreDeclarationExceptions

  public void setIgnoreDeclarationExceptions(boolean ignoreDeclarationExceptions)

• setTaskExecutor

  public void setTaskExecutor(TaskExecutor taskExecutor)

  非同期操作に使用するタスクエグゼキュータを設定します。現在、purgeQueue(String, boolean) でのみ使用されています。

  パラメーター:

  taskExecutor - 使用するエグゼキュータ。

• setExplicitDeclarationsOnly

  public void setExplicitDeclarationsOnly(boolean explicitDeclarationsOnly)

  この管理者によって宣言されるように明示的に構成されている Declarable Bean のみを宣言するには、true に設定します。

  パラメーター:

  explicitDeclarationsOnly - admin 宣言構成のない Bean を無視する場合は true。

• getLastDeclarationExceptionEvent

  public @Nullable DeclarationExceptionEvent getLastDeclarationExceptionEvent()

  戻り値:

  この管理者で検出された最後の DeclarationExceptionEvent。

• isAutoStartup

  public boolean isAutoStartup()

  次で指定:

  インターフェース SmartLifecycle の isAutoStartup 

• setAutoStartup

  public void setAutoStartup(boolean autoStartup)

• getPhase

  public int getPhase()

  次で指定:

  インターフェース Phased の getPhase 

  次で指定:

  インターフェース SmartLifecycle の getPhase 

• start

  public void start()

  次で指定:

  インターフェース Lifecycle の start 

• stop

  public void stop()

  次で指定:

  インターフェース Lifecycle の stop 

• isRunning

  public boolean isRunning()

  次で指定:

  インターフェース Lifecycle の isRunning 

• initialize

  public void initialize()

  含まれているアプリケーションコンテキスト内のすべての交換、キュー、バインディングを宣言します (存在する場合)。このメソッドを複数回呼び出しても安全です (ただし不要です)。

  次で指定:

  インターフェース AmqpAdmin の initialize 

• declareExchange

  public void declareExchange(Exchange exchange)

  インターフェースからコピーされた説明: AmqpAdmin

  交換を宣言します。

  次で指定:

  インターフェース AmqpAdmin の declareExchange 

  パラメーター:

  exchange - 宣言する交換。

• deleteExchange

  @ManagedOperation(description="Delete an exchange from the broker") public boolean deleteExchange(StringSE exchangeName)

  インターフェースからコピーされた説明: AmqpAdmin

  交換を削除します。実装固有の動作については、実装固有のサブクラスを参照してください。たとえば、RabbitMQ の場合、使用中かどうかに関係なく交換が削除されます。

  次で指定:

  インターフェース AmqpAdmin の deleteExchange 

  パラメーター:

  exchangeName - 取引所の名前

  戻り値:

  交換が存在し、削除された場合は true

• declareQueue

  public @Nullable Queue declareQueue()

  インターフェースからコピーされた説明: AmqpAdmin

  名前が自動的に付けられるキューを宣言します。これは、exclusive = true、autoDelete = true、durable = false で作成されます。

  次で指定:

  インターフェース AmqpAdmin の declareQueue 

  戻り値:

  待ち行列。

• declareQueue

  public @Nullable StringSE declareQueue(Queue queue)

  インターフェースからコピーされた説明: AmqpAdmin

  指定されたキューを宣言します。

  次で指定:

  インターフェース AmqpAdmin の declareQueue 

  パラメーター:

  queue - 宣言するキュー。

  戻り値:

  キューの名前。

• deleteQueue

  @ManagedOperation(description="Delete a queue from the broker") public boolean deleteQueue(StringSE queueName)

  インターフェースからコピーされた説明: AmqpAdmin

  使用中かメッセージがあるかに関係なく、キューを削除します。

  次で指定:

  インターフェース AmqpAdmin の deleteQueue 

  パラメーター:

  queueName - キューの名前。

  戻り値:

  キューが存在し、削除された場合は true。

• deleteQueue

  @ManagedOperation(description="Delete a queue from the broker if unused and empty (when corresponding arguments are true") public void deleteQueue(StringSE queueName, boolean unused, boolean empty)

  インターフェースからコピーされた説明: AmqpAdmin

  キューを削除します。

  次で指定:

  インターフェース AmqpAdmin の deleteQueue 

  パラメーター:

  queueName - キューの名前。

  unused - 使用されていない場合にのみキューを削除する必要がある場合は true。

  empty - 空の場合にのみキューを削除する場合は true。

• purgeQueue

  @ManagedOperation(description="Purge a queue and optionally don't wait for the purge to occur") public void purgeQueue(StringSE queueName, boolean noWait)

  インターフェースからコピーされた説明: AmqpAdmin

  指定されたキューの内容をパージします。

  次で指定:

  インターフェース AmqpAdmin の purgeQueue 

  パラメーター:

  queueName - キューの名前。

  noWait - パージの完了を待たない場合は true。

• purgeQueue

  @ManagedOperation(description="Purge a queue and return the number of messages purged") public int purgeQueue(StringSE queueName)

  インターフェースからコピーされた説明: AmqpAdmin

  指定されたキューの内容をパージします。

  次で指定:

  インターフェース AmqpAdmin の purgeQueue 

  パラメーター:

  queueName - キューの名前。

  戻り値:

  パージされたメッセージの数。

• declareBinding

  public void declareBinding(Binding binding)

  インターフェースからコピーされた説明: AmqpAdmin

  交換へのキューのバインディングを宣言します。

  次で指定:

  インターフェース AmqpAdmin の declareBinding 

  パラメーター:

  binding - 宣言するバインディングの説明。

• removeBinding

  public void removeBinding(Binding binding)

  インターフェースからコピーされた説明: AmqpAdmin

  キューの交換へのバインディングを削除します。unbindQueue/removeBinding は仕様の 0.9 まで導入されなかったことに注意してください。

  次で指定:

  インターフェース AmqpAdmin の removeBinding 

  パラメーター:

  binding - 削除するバインディングの説明。

• getQueueProperties

  @ManagedOperation(description="Get queue name, message count and consumer count") public @Nullable PropertiesSE getQueueProperties(StringSE queueName)

  4 つのプロパティ RabbitAdmin.QUEUE_NAME、RabbitAdmin.QUEUE_MESSAGE_COUNT、RabbitAdmin.QUEUE_CONSUMER_COUNT、QUEUE_TYPE を返します。キューが存在しない場合は null を返します。

  次で指定:

  インターフェース AmqpAdmin の getQueueProperties 

  パラメーター:

  queueName - キューの名前。

  戻り値:

  プロパティ、またはキューが存在しない場合は null。

• getQueueInfo

  public @Nullable QueueInformation getQueueInfo(StringSE queueName)

  インターフェースからコピーされた説明: AmqpAdmin

  キューが存在する場合は、キューに関する情報を返します。

  次で指定:

  インターフェース AmqpAdmin の getQueueInfo 

  パラメーター:

  queueName - キューの名前。

  戻り値:

  情報、またはキューが存在しない場合は null。