Do same for host port on deregister

2019-08-15 08:59:50 +01:00 · 2019-08-15 08:59:50 +01:00 · a42de29f67
commit a42de29f67
parent 0f6d09af33
1 changed files with 6 additions and 1 deletions
--- a/server/rpc_server.go
+++ b/server/rpc_server.go
@ -453,9 +453,14 @@ func (s *rpcServer) Deregister() error {
 		return err
 	}

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

 	service := &registry.Service{