internal/broker: fix clobbered context (#411)

emitter-io · Sep 20, 2023 · bb61442 · bb61442
1 parent 752dc57
commit bb61442
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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()