core/oc-lib
5
0
Fork 0
Code Issues 3 Pull Requests Packages Projects Releases Wiki Activity

nats discovery

Browse Source
This commit is contained in:
mr 2024-10-17 16:04:07 +02:00
parent 1561d0c81e
commit 3e7f8513eb
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tools/api.go
View File

@ -86,10 +86,10 @@ func (a *API) ListenRouter(exec func(msg map[string]interface{})) {
go NewNATSCaller().ListenNats(DISCOVERY.GenerateKey("api"), exec) go NewNATSCaller().ListenNats(DISCOVERY.GenerateKey("api"), exec)
} }
func (a *API) SubscribeRouter() { func (a *API) SubscribeRouter(infos []*beego.ControllerInfo) {
nats := NewNATSCaller() nats := NewNATSCaller()
discovery := map[string]interface{}{} discovery := map[string]interface{}{}
for _, info := range beego.BeeApp.Handlers.GetAllControllerInfo() { for _, info := range infos {
methods := []string{} methods := []string{}
for k := range info.GetMethod() { for k := range info.GetMethod() {
methods = append(methods, k) methods = append(methods, k)