fix registry addr error for mq-rpc

2019-08-14 21:32:28 +08:00
parent dc0fbfc3c0
commit bf0e46dc0d
3 changed files with 17 additions and 7 deletions
--- a/server/rpc_server.go
+++ b/server/rpc_server.go
@@ -316,10 +316,15 @@ func (s *rpcServer) Register() error {
 		md[k] = v
 	}

+	// mq-rpc(eg. nats) doesn't need the port. its addr is queue name.
+	if port != "" {
+		addr = mnet.HostPort(addr, port)
+	}
+
 	// register service
 	node := &registry.Node{
 		Id:       config.Name + "-" + config.Id,
-		Address:  mnet.HostPort(addr, port),
+		Address:  addr,
 		Metadata: md,
 	}