Contents

module QuSpec
  module SchedulerExtension
    def enqueue_at(time, klass, *args)
      QuSpec.enqueue_at(time, klass, *args)
    end

    def enqueue_in(time, klass, *args)
      QuSpec.enqueue_in(time, klass, *args)
    end

    def remove_delayed(klass, *args)
      QuSpec.remove_delayed(klass, *args)
    end
  end

  def self.enqueue_at(time, klass, *args)
    Qu.backend.delayed_push(time, Qu::Payload.new(:klass => klass, :args => args))
  end

  def self.enqueue_in(time, klass, *args)
    enqueue_at(Time.now + time, klass, *args)
  end

  def self.remove_delayed(klass, *args)
    Qu.backend.remove_delayed(klass, *args)
  end

  def self.schedule_for(klass)
    Qu.backend.get_schedule_by_klass(klass)
  end
end

Qu.send :extend, QuSpec::SchedulerExtension

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
qu-spec-0.2.0	lib/qu-spec/scheduler.rb