在Rabbitmq中，我有一个队列“aggregator”绑定到交换“Exhange1”，路由键为“agg.*"。消息通过动态生成器correlation_id发布到此队列。假设correlation_id='1234'的消息被发布到这个交换，消费者只想消费这个特定的消息，而不消费其他消息，并发送回去，直到我得到correlation_id=1234。
这个问题与基于路由键的消息隔离无关
基本上，我想应用correlation_id作为过滤器，并使用特定的消息而不使用所有消息，因为Rabbitmq文档说它的反模式。
1条答案
按热度按时间xeufq47z1#
RabbitMQ以FIFO顺序传递消息。没有办法将特定的消息出队。
主题交换可以解决您的用例。不要忘记，消费者可以使用任何适合用例的绑定参数，使用自己的独占队列绑定到交易所。