mangos.go
@@ -16,7 +16,7 @@ svr *gopherdiscovery.DiscoveryServer cli *gopherdiscovery.DiscoveryClient cliInfo map[string]interface{} cliInfo map[string][]byte recvCh chan Message //recv msg chan } @@ -158,14 +158,14 @@ return ps.recvCh } func (ps *mangosPubSub) GetCliInfo() map[string]interface{} { func (ps *mangosPubSub) GetCliInfo() map[string][]byte { if ps.svr != nil { return ps.cliInfo } return nil } func (ps *mangosPubSub) SetResp(r interface{}) { func (ps *mangosPubSub) SetResp(r []byte) { if ps.cli != nil { ps.cli.SetResp(r) }