Contents

module CukeQ

  #
  # TODO: must be a better way
  #

  class JobClearer < Slave

    def poll
      EM.next_tick {
        job = @broker.queue_for(:jobs).pop
        log(self.class, :ignoring, job)
        poll
      }
    end

  end # JobClearer
end # CukeQ

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
cukeq-0.0.1.dev5	lib/cukeq/job_clearer.rb
cukeq-0.0.1.dev4	lib/cukeq/job_clearer.rb
cukeq-0.0.1.dev3	lib/cukeq/job_clearer.rb
cukeq-0.0.1.dev2	lib/cukeq/job_clearer.rb
cukeq-0.0.1.dev	lib/cukeq/job_clearer.rb