strip sub comments
This commit is contained in:
parent
3a1515040f
commit
e45a20a7f3
2
grpc.go
2
grpc.go
@ -653,7 +653,7 @@ func (g *grpcServer) Register() error {
|
|||||||
opts = append(opts, broker.DisableAutoAck())
|
opts = append(opts, broker.DisableAutoAck())
|
||||||
}
|
}
|
||||||
|
|
||||||
log.Logf("Broker [%s] Subscribing to topic: %s", config.Broker.String(), sb.Topic())
|
log.Logf("Subscribing to topic: %s", sb.Topic())
|
||||||
sub, err := config.Broker.Subscribe(sb.Topic(), handler, opts...)
|
sub, err := config.Broker.Subscribe(sb.Topic(), handler, opts...)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
Loading…
Reference in New Issue
Block a user