Browse Source

log update

0xdcarns 3 years ago
parent
commit
6effabd061
1 changed files with 1 additions and 1 deletions
  1. 1 1
      mq/publishers.go

+ 1 - 1
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 {
 		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)
 			logger.Log(1, "failed to publish peer update for node", node.ID)
 		} else {
 		} 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)
 				logger.Log(1, "sent peer update for node", node.Name, "on network:", node.Network)
 			}
 			}
 		}
 		}