diff --git a/checks/rabbitmq/check.go b/checks/rabbitmq/check.go index e4c50bd..c7b6a04 100644 --- a/checks/rabbitmq/check.go +++ b/checks/rabbitmq/check.go @@ -106,9 +106,10 @@ func New(config Config) func(ctx context.Context) error { // release the channel resources, and unblock the receive on done below close(done) - // now drain any incidental remaining messages + //revive:disable:empty-block Draining any incidental remaining messages for range messages { } + //revive:enable:empty-block }() p := amqp.Publishing{Body: []byte(time.Now().Format(time.RFC3339Nano))}