Merge pull request #33 from dnstapir/paho-queue-context

Use already existing context for queue publishing
dnstapir · Dec 6, 2024 · be0f829 · be0f829
2 parents d209942 + 14e65e1
commit be0f829
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,