From acf5efb69a486eeee88b1e6d501343d259dbf29a Mon Sep 17 00:00:00 2001
From: 0xdcarns <dillon.carns@gmail.com>
Date: Fri, 1 Jul 2022 10:25:00 -0400
Subject: [PATCH] added leader check

---
 mq/handlers.go | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/mq/handlers.go b/mq/handlers.go
index 94db2b85..5c4f8011 100644
--- a/mq/handlers.go
+++ b/mq/handlers.go
@@ -132,8 +132,10 @@ func updateNodePeers(currentNode *models.Node) {
 		logger.Log(1, "server node:", currentServerNode.ID, "failed update")
 		return
 	}
-	if err := PublishPeerUpdate(currentNode); err != nil {
-		logger.Log(1, "error publishing peer update ", err.Error())
-		return
+	if logic.IsLeader(&currentServerNode) {
+		if err := PublishPeerUpdate(currentNode); err != nil {
+			logger.Log(1, "error publishing peer update ", err.Error())
+			return
+		}
 	}
 }