Forwarder: propagate the enveloped message's Context (ThreeDotsLabs#387)

m110 · web-flow · commit 4f3079b3e43d · 2023-09-05T22:56:59.000+02:00
This may be useful if the Forwarder's router middleware changes the
Context in some way.
diff --git 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
 }

Original file line number	Diff line number	Diff line change
`@@ -69,6 +69,7 @@ func unwrapMessageFromEnvelope(msg *message.Message) (destinationTopic string, u`
`69`	`69`
`70`	`70`	`watermillMessage := message.NewMessage(envelopedMsg.UUID, envelopedMsg.Payload)`
`71`	`71`	`watermillMessage.Metadata = envelopedMsg.Metadata`
	`72`	`+ watermillMessage.SetContext(msg.Context())`
`72`	`73`
`73`	`74`	`return envelopedMsg.DestinationTopic, watermillMessage, nil`
`74`	`75`	`}`