Browse Source

changing peer set

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

+ 2 - 0
mq/mq.go

@@ -127,6 +127,8 @@ 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 {
+			logger.Log(0, "sent peer update for network, %s and node, %s, peers sent: \n%v", node.Network, node.Name, string(data))
 		}
 		}
 	}
 	}
 	return nil
 	return nil