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