0


rabbitmq自动创建队列

在学习springAMQP时遇到了一个问题在使用下方代码时候,rabbitmq控制台不能自动创建queue

只能自己手动添加队列后message才会存入队列中。

    @Test
    public void testSendMessage2SimpleQueue() {
        String queueName = "queue1";
        String message = "message1";
        rabbitTemplate.convertAndSend(queueName, message);
    }

解决方法

加上注解,填上队列名就会在运行时自动创建队列了

  @Test
    @RabbitListener(queuesToDeclare = @Queue("queue2"))
    public void testSendMessage2SimpleQueue() {
        String queueName = "queue2";
        String message = "queue2";
        rabbitTemplate.convertAndSend(queueName, message);
    }
标签: rabbitmq 分布式

本文转载自: https://blog.csdn.net/hagong9/article/details/128221986
版权归原作者 hagong9 所有, 如有侵权,请联系我们删除。

“rabbitmq自动创建队列”的评论:

还没有评论