From 387dbc8271641bf19681b9b1d6539ec43f9d78dc Mon Sep 17 00:00:00 2001 From: Lars Lehtonen Date: Tue, 19 Sep 2023 09:35:23 -0700 Subject: [PATCH] internal/broker: fix clobbered context --- internal/broker/service.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/broker/service.go b/internal/broker/service.go index be08e1f6..53d7c46b 100644 --- a/internal/broker/service.go +++ b/internal/broker/service.go @@ -78,7 +78,7 @@ type Service struct { // NewService creates a new service. func NewService(ctx context.Context, cfg *config.Config) (s *Service, err error) { - ctx, cancel := context.WithCancel(context.Background()) + ctx, cancel := context.WithCancel(ctx) var trie *message.Trie if "mqtt" == cfg.Matcher { trie = message.NewTrieMQTT()