Browse Source

Merge pull request #975 from gravitl/feature_v0.12.2_ext_peer_updates

mq/publishers: Added network wide peer updates for ext peer updates
dcarns 3 years ago
parent
commit
4d6f5e5163
1 changed files with 5 additions and 1 deletions
  1. 5 1
      mq/publishers.go

+ 5 - 1
mq/publishers.go

@@ -69,7 +69,11 @@ func PublishExtPeerUpdate(node *models.Node) error {
 	if err != nil {
 		return err
 	}
-	return publish(node, fmt.Sprintf("peers/%s/%s", node.Network, node.ID), data)
+	if err = publish(node, fmt.Sprintf("peers/%s/%s", node.Network, node.ID), data); err != nil {
+		return err
+	}
+	go PublishPeerUpdate(node)
+	return nil
 }
 
 // NodeUpdate -- publishes a node update