diff --git a/builder.go b/builder.go index f981efce66163df23fca0d69b548e1697fc54228..a888f04907e9289cac752b80267d56ce33cf5a95 100644 --- a/builder.go +++ b/builder.go @@ -132,6 +132,7 @@ func (o *dispatcher) doHeader() { "Mq-Message-Consumed-Count": o.message.ConsumedCount, "Mq-Message-Delay-Milliseconds": o.message.Delay.Milliseconds(), "Mq-Message-Id": o.message.MessageId, + "Mq-Message-Queue": o.message.Queue, "Mq-Message-Tag": o.message.Tag, "Mq-Message-Time": o.message.Time.Format(time.RFC3339Nano), "Mq-Message-Topic": o.message.Topic,