Use already existing context for queue publishing

dnstapir · Nov 29, 2024 · 14e65e1 · 14e65e1
1 parent d209942
commit 14e65e1
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/pkg/runner/mqtt.go b/pkg/runner/mqtt.go
@@ -1,7 +1,6 @@
 package runner
 
 import (
-	"context"
 	"crypto/tls"
 	"crypto/x509"
 	"fmt"
@@ -121,7 +120,7 @@ func (edm *dnstapMinimiser) runAutoPaho(cm *autopaho.ConnectionManager, topic st
 		}
 
 		if usingFileQueue {
-			err = cm.PublishViaQueue(context.Background(), &autopaho.QueuePublish{
+			err = cm.PublishViaQueue(edm.autopahoCtx, &autopaho.QueuePublish{
 				Publish: &paho.Publish{
 					QoS:     0,
 					Topic:   topic,