diff --git a/grpc.go b/grpc.go index 08c771e..b039c02 100644 --- 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