AmqpAdmin.deleteQueue()方法在删除队列时不会重新声明。如果需要在删除队列后重新声明,可以使用以下代码示例:
@Autowired
private AmqpAdmin amqpAdmin;
public void deleteAndRecreateQueue(String queueName, Queue queue) {
// 删除队列
amqpAdmin.deleteQueue(queueName);
// 重新声明队列
amqpAdmin.declareQueue(queue);
}
这段代码首先使用AmqpAdmin.deleteQueue()方法删除队列,然后使用AmqpAdmin.declareQueue()方法重新声明队列。这样就可以同步删除和重新声明队列。
下一篇:AMQP传输帧被拒绝