From 89f1dce976e3cc1375d58763f86e54691d831a6a Mon Sep 17 00:00:00 2001 From: James Wells Date: Fri, 15 Jul 2022 06:38:21 -0700 Subject: [PATCH] Restoring connector for worker. --- internal/worker/worker.go | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/internal/worker/worker.go b/internal/worker/worker.go index 89766e4..8cebdb8 100644 --- a/internal/worker/worker.go +++ b/internal/worker/worker.go @@ -57,9 +57,7 @@ func getAgent(wg *sync.WaitGroup, uuid string, connectString string) { subscriber, _ := zmq.NewSocket(zmq.REP) defer subscriber.Close() - // _ = subscriber.Connect(connectString) - foo := subscriber.Connect(connectString) - log.Printf("[DEBUG] Connected to %s\n", foo) + _ = subscriber.Connect(connectString) msg, err := subscriber.Recv(0) if err != nil {