Browse Source

added isserver check

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

+ 3 - 0
mq/mq.go

@@ -116,6 +116,9 @@ func PublishPeerUpdate(newNode *models.Node) error {
 			logger.Log(1, "error getting peer update for node", node.ID, err.Error())
 			logger.Log(1, "error getting peer update for node", node.ID, err.Error())
 			continue
 			continue
 		}
 		}
+		if node.IsServer == "yes" {
+			continue
+		}
 		data, err := json.Marshal(&peerUpdate)
 		data, err := json.Marshal(&peerUpdate)
 		if err != nil {
 		if err != nil {
 			logger.Log(2, "error marshaling peer update for node", node.ID, err.Error())
 			logger.Log(2, "error marshaling peer update for node", node.ID, err.Error())