Contents

module Qujo
  module Queue
    module Resque
      class JobWorker
        @queue = :default

        class << self
          def perform(options={})
            id = options["id"]
            job = ::Job.find(id)
            logger.info "JobWorker:perform #{job.class} #{id}"
            job.run
          rescue => e
            logger.error e.message
            logger.error e
          end

          def logger
            Qujo.logger
          end
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
qujo-0.1.4	lib/qujo/queue/resque/job_worker.rb
qujo-0.1.3	lib/qujo/queue/resque/job_worker.rb
qujo-0.1.2	lib/qujo/queue/resque/job_worker.rb
qujo-0.1.1	lib/qujo/queue/resque/job_worker.rb
qujo-0.1.0	lib/qujo/queue/resque/job_worker.rb