From 384427cd3e73c1a9715b8e47bdfcbf6a646f6a72 Mon Sep 17 00:00:00 2001 From: Geoffrey Ragot Date: Fri, 18 Mar 2022 14:36:39 +0100 Subject: [PATCH] Add missing context to watermill messages. --- pkg/bus/message.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pkg/bus/message.go b/pkg/bus/message.go index b9bf8abb3..d2572a582 100644 --- a/pkg/bus/message.go +++ b/pkg/bus/message.go @@ -16,7 +16,9 @@ func newMessage(ctx context.Context, m interface{}) *message.Message { if err != nil { panic(err) } - return message.NewMessage(uuid.New(), data) + msg := message.NewMessage(uuid.New(), data) + msg.SetContext(ctx) + return msg } type baseEvent struct {