server.go @@ -242,5 +242,5 @@ } func (d *DiscoveryServer) PublishMsg(msg protomsg.PublishMessage){ d.services.publisher.Publish([]string{msg}) d.services.publisher.Publish([]string{string(msg)}) }