Add broker and server to metadata

2016-01-04 01:27:05 +00:00 · 2016-01-04 01:27:05 +00:00 · 227adc490c
commit 227adc490c
parent ecdaea7a67
1 changed files with 2 additions and 0 deletions
--- a/server/rpc_server.go
+++ b/server/rpc_server.go
@ -192,6 +192,8 @@ func (s *rpcServer) Register() error {
 	}

 	node.Metadata["transport"] = config.Transport.String()
+	node.Metadata["broker"] = config.Broker.String()
+	node.Metadata["server"] = s.String()

 	s.RLock()
 	var endpoints []*registry.Endpoint