我正在使用Go编写一个服务,并使用RabbitMQ进行消息传递。我需要在消息头中添加信息,这些信息应该包含消息流经的位置,它应该在消息头中添加exchange名称或queue名称。有人能告诉我这是怎么做到的吗?
exchange
queue
camsedfj1#
每一个传递的消息都有一组属性。其中两个是用于路由消息的交换和路由键。根据交换的类型,您还可以根据此信息确定队列名称。https://www.rabbitmq.com/amqp-0-9-1-quickref.html如果你需要知道消息何时发布,你可以使用这个插件-https://github.com/rabbitmq/rabbitmq-message-timestamp
1条答案
按热度按时间camsedfj1#
每一个传递的消息都有一组属性。其中两个是用于路由消息的交换和路由键。根据交换的类型,您还可以根据此信息确定队列名称。
https://www.rabbitmq.com/amqp-0-9-1-quickref.html
如果你需要知道消息何时发布,你可以使用这个插件-https://github.com/rabbitmq/rabbitmq-message-timestamp