def purge(release: false)
      mutex.synchronize do
        check_process!

        log(:debug) { "Purge all queues on #{uri}..." }

        connection.purge(release: release)
      end
    end
def purge(release: false)
      mutex.synchronize do
        check_process!

        log(:debug) { "Purge all queues on #{uri}..." }

        connection.purge(release: release)
      end
    end
rubocop:enable all