From fc08a9146cc6ef2dcc1d556f5396ac2de86b33eb Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Sun, 19 Jan 2020 01:16:36 +0000 Subject: [PATCH] Add broker comments on server subscribe --- server/grpc/grpc.go | 1 + server/rpc_server.go | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/server/grpc/grpc.go b/server/grpc/grpc.go index 08c771e3..b039c021 100644 --- a/server/grpc/grpc.go +++ b/server/grpc/grpc.go @@ -653,6 +653,7 @@ func (g *grpcServer) Register() error { opts = append(opts, broker.DisableAutoAck()) } + log.Logf("Broker [%s] Subscribing to topic: %s", config.Broker.String(), sb.Topic()) sub, err := config.Broker.Subscribe(sb.Topic(), handler, opts...) if err != nil { return err diff --git a/server/rpc_server.go b/server/rpc_server.go index 7d1642ff..5f7f08d4 100644 --- a/server/rpc_server.go +++ b/server/rpc_server.go @@ -654,12 +654,12 @@ func (s *rpcServer) Register() error { opts = append(opts, broker.DisableAutoAck()) } + log.Logf("Broker [%s] Subscribing to topic: %s", config.Broker.String(), sub.Topic()) sub, err := config.Broker.Subscribe(sb.Topic(), s.HandleEvent, opts...) if err != nil { return err } - log.Logf("Subscribing %s to topic: %s", node.Id, sub.Topic()) s.subscribers[sb] = []broker.Subscriber{sub} }