diff --git a/checks/rabbitmq/check.go b/checks/rabbitmq/check.go index c7b6a04..135da55 100644 --- a/checks/rabbitmq/check.go +++ b/checks/rabbitmq/check.go @@ -105,11 +105,6 @@ func New(config Config) func(ctx context.Context) error { // release the channel resources, and unblock the receive on done below close(done) - - //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))}