rabbitmq-queueDelete
当客户端channel把消费者和queue绑定,然后channel再把queue删掉时,这个事件是可以监听到的:
private final String queue = "cancel_notification_queue";
public void testConsumerCancellationNotification() throws IOException,
InterruptedException {
final BlockingQueue<Boolean> result = new ArrayBlockingQueue<Boolean>(1);
channel.queueDeclare(queue, false, true, false, null);
Consumer consumer = new QueueingConsumer(channel) {
@Override
public void handleCancel(String consumerTag) throws IOException {
try {
result.put(true);
} catch (InterruptedException e) {
fail();
}
}
};
channel.basicConsume(queue, consumer);
channel.queueDelete(queue);//删除queue
assertTrue(result.take());
}
- rabbitmq 学习-8- Exchange Queue RoutingKey关系说明
- rabbitmq java queue
- 创建rabbitmq:virtual host、exchange、queue
- rabbitmq队列的exclusive,durability,auto-delete属性以及消息可靠传输设计
- RabbitMq的整理 exchange、route、queue关系
- rabbitmq 3 entities之 queue
- rabbitmq-queueDeclareNoWait
- (七)RabbitMQ消息队列-通过fanout模式将消息推送到多个Queue中
- springboot整合rabbitmq,动态创建queue和监听queue
- Java使用Rabbitmq惊喜队列queue和消息内容的本地持久化核心方法。(内容存储在硬盘)
- 【原创】RabbitMQ 中批量删除 queue 的方法
- RabbitMQ中 exchange、route、queue的关系
- rabbitmq-queueDeclarePassive
- delete queue
- RabbitMQ 声明Queue时的参数们的Power
- RabbitMQ(python实现)学习之二:Producer发送消息至多个消息队列queue(广播消息)
- spring-boot整合rabbitmq启动报错no queue 'dev_pms2invoi_queue' in vhost '/'
- 搭建高可用的rabbitmq集群 + Mirror Queue + 使用C#驱动连接
- rabbitmq监控queue中message数量
- RabbitMQ Queue分发多个Consumer