dragonheim/gagent
dragonheim/gagent
1
0
Fork 0
mirror of https://github.com/dragonheim/gagent.git synced 2025-01-18 09:36:28 -08:00
Code Issues Projects Releases Packages Wiki Activity Actions

Restoring connector for worker.

Browse source
This commit is contained in:
James Wells 2022-07-15 06:38:21 -07:00
parent 134f33cd6a
commit 89f1dce976
Signed by: jwells
GPG key ID: 73196D10B8E65666
1 changed files with 1 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
internal/worker/worker.go
View file

@ -57,9 +57,7 @@ func getAgent(wg *sync.WaitGroup, uuid string, connectString string) {
subscriber, _ := zmq.NewSocket(zmq.REP) subscriber, _ := zmq.NewSocket(zmq.REP)
defer subscriber.Close() defer subscriber.Close()
// _ = subscriber.Connect(connectString) _ = subscriber.Connect(connectString)
foo := subscriber.Connect(connectString)
log.Printf("[DEBUG] Connected to %s\n", foo)
msg, err := subscriber.Recv(0) msg, err := subscriber.Recv(0)
if err != nil { if err != nil {