From 4f3079b3e43d106ab638f3f656f9bb101f49361c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mi=C5=82osz=20Sm=C3=B3=C5=82ka?= Date: Tue, 5 Sep 2023 22:56:59 +0200 Subject: [PATCH] Forwarder: propagate the enveloped message's Context (#387) This may be useful if the Forwarder's router middleware changes the Context in some way. --- components/forwarder/envelope.go | 1 + 1 file changed, 1 insertion(+) diff --git a/components/forwarder/envelope.go b/components/forwarder/envelope.go index 9a4784666..b8de18763 100644 --- a/components/forwarder/envelope.go +++ b/components/forwarder/envelope.go @@ -69,6 +69,7 @@ func unwrapMessageFromEnvelope(msg *message.Message) (destinationTopic string, u watermillMessage := message.NewMessage(envelopedMsg.UUID, envelopedMsg.Payload) watermillMessage.Metadata = envelopedMsg.Metadata + watermillMessage.SetContext(msg.Context()) return envelopedMsg.DestinationTopic, watermillMessage, nil }