From 4a7395872520e934b6cdb28e8ae522f31ee654f3 Mon Sep 17 00:00:00 2001 From: 0xdcarns Date: Tue, 8 Feb 2022 19:52:35 -0500 Subject: [PATCH] comment changed --- main.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/main.go b/main.go index bb26418d..5b94ef20 100644 --- a/main.go +++ b/main.go @@ -185,8 +185,7 @@ func runGRPC(wg *sync.WaitGroup) { func runMessageQueue(wg *sync.WaitGroup) { defer wg.Done() logger.Log(0, fmt.Sprintf("connecting to mq broker at %s", servercfg.GetMessageQueueEndpoint())) - var client = mq.SetupMQTT(false) - // Set Up Keepalive message + var client = mq.SetupMQTT(false) // Set up the subscription listener ctx, cancel := context.WithCancel(context.Background()) go mq.Keepalive(ctx) quit := make(chan os.Signal, 1)