We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9c09c88 commit a72e180Copy full SHA for a72e180
rabbitmq/broker.go
@@ -211,9 +211,9 @@ func (br *Broker) Receive() ([]byte, error) {
211
properties["reply_to"] = msg.ReplyTo
212
properties["delivery_mode"] = msg.DeliveryMode
213
delivery_info := make(map[string]interface{})
214
- properties["delivery_info"] = delivery_info
215
delivery_info["exchange"] = msg.Exchange
216
delivery_info["routing_key"] = msg.RoutingKey
+ properties["delivery_info"] = delivery_info
217
properties["priority"] = msg.Priority
218
properties["body_encoding"] = "base64"
219
properties["delivery_tag"] = msg.DeliveryTag
0 commit comments