diff --git a/mq/publishers.go b/mq/publishers.go index 8cace2e1..299d4e22 100644 --- a/mq/publishers.go +++ b/mq/publishers.go @@ -38,7 +38,7 @@ func PublishPeerUpdate(newNode *models.Node) error { if err = publish(&node, fmt.Sprintf("peers/%s/%s", node.Network, node.ID), data); err != nil { logger.Log(1, "failed to publish peer update for node", node.ID) } else { - if node.CommID != servercfg.GetCommsID() { + if node.Network != servercfg.GetCommsID() { logger.Log(1, "sent peer update for node", node.Name, "on network:", node.Network) } }