在这种情况下,声明一个队列、将generateinvoice消息发布到队列以及拥有该队列的多个使用者。
发布到队列的消息不会丢失,如果没有消费者,它们将保留在RMQ上。唯一的事情是确保在消息发布之前声明队列。
Java示例:
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
然后,发布可以执行如下操作:
channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
消费可以做到:
channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> { });