Add broker comments on server subscribe

2020-01-19 01:16:36 +00:00 · 2020-01-19 01:16:36 +00:00 · ab6334fad1
commit ab6334fad1
parent df710d9efc
1 changed files with 1 additions and 0 deletions
--- a/grpc.go
+++ b/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