diff --git a/tools/api.go b/tools/api.go index bbe0a69..2071356 100644 --- a/tools/api.go +++ b/tools/api.go @@ -61,8 +61,12 @@ func (s State) String() string { type API struct{} func (a *API) Discovered(infos []*beego.ControllerInfo) { - respondToDiscovery := func(m NATSResponse) { - a.SubscribeRouter(infos) + respondToDiscovery := func(resp NATSResponse) { + var m map[string]interface{} + json.Unmarshal(resp.Payload, &m) + if len(m) == 0 { + a.SubscribeRouter(infos) + } } a.ListenRouter(respondToDiscovery) a.SubscribeRouter(infos)