DISCOVERY

tools/api.go

@@ -92,7 +92,7 @@ func (a *API) GetState() (State, int, error) {
 }
 
 func (a *API) ListenRouter(exec func(msg map[string]string)) {
-	go NewNATSCaller().ListenNats(DISCOVERY.GenerateKey(), map[NATSMethod]func(msg map[string]string){
+	go NewNATSCaller().ListenNats(map[NATSMethod]func(msg map[string]string){
 		DISCOVERY: exec,
 	})
 }
@@ -113,7 +113,7 @@ func (a *API) SubscribeRouter(infos []*beego.ControllerInfo) {
 			}
 		}
 	}
-	go nats.SetNATSPub("api", DISCOVERY, discovery)
+	go nats.SetNATSPub(DISCOVERY, discovery)
 }
 
 // CheckRemotePeer checks the state of a remote peer