From 7e8bcd6923bca15d9cf9be22b9a5eb99787dff08 Mon Sep 17 00:00:00 2001 From: Matthew R Kasun Date: Sat, 22 Jan 2022 09:22:19 -0500 Subject: [PATCH] remove / in topic name --- mq/mq.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mq/mq.go b/mq/mq.go index 6ae57942..1405418d 100644 --- a/mq/mq.go +++ b/mq/mq.go @@ -133,7 +133,7 @@ func NodeUpdate(node *models.Node) error { logger.Log(2, "error marshalling node update "+err.Error()) return err } - if token := client.Publish("/update/"+node.ID, 0, false, data); token.Wait() && token.Error() != nil { + if token := client.Publish("update/"+node.ID, 0, false, data); token.Wait() && token.Error() != nil { logger.Log(2, "error publishing peer update to peer "+node.ID+" "+token.Error().Error()) return err }