Преглед на файлове

remove mq check for peerUpdate

Max Ma преди 1 година
родител
ревизия
90ca11f48d
променени са 1 файла, в които са добавени 2 реда и са изтрити 4 реда
  1. 2 4
      controllers/network.go

+ 2 - 4
controllers/network.go

@@ -491,10 +491,8 @@ func createNetwork(w http.ResponseWriter, r *http.Request) {
 			logic.CreateIngressGateway(network.NetID, newNode.ID.String(), models.IngressRequest{})
 		}
 		// send peer updates
-		if servercfg.IsMessageQueueBackend() {
-			if err = mq.PublishPeerUpdate(false); err != nil {
-				logger.Log(1, "failed to publish peer update for default hosts after network is added")
-			}
+		if err = mq.PublishPeerUpdate(false); err != nil {
+			logger.Log(1, "failed to publish peer update for default hosts after network is added")
 		}
 	}()