Contents

require 'evrone/common/amqp'

module Evrone
  module CI
    module Worker
      class JobsConsumer

        include Evrone::Common::AMQP::Consumer

        exchange 'ci.jobs'
        queue    'ci.worker.jobs.generic'
        ack      true

        model Message::PerformJob

        def perform(message)
          job         = Job.new message
          number      = Thread.current[:consumer_id] || 0
          path_prefix = "/tmp/.test/job.#{number}"
          Worker.perform(job, path_prefix)
          ack!
        end

      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
evrone-ci-worker-0.2.0.pre6	lib/evrone/ci/worker/consumers/jobs_consumer.rb
evrone-ci-worker-0.2.0.pre5	lib/evrone/ci/worker/consumers/jobs_consumer.rb
evrone-ci-worker-0.2.0.pre4	lib/evrone/ci/worker/consumers/jobs_consumer.rb
evrone-ci-worker-0.2.0.pre3	lib/evrone/ci/worker/consumers/jobs_consumer.rb
evrone-ci-worker-0.2.0.pre1	lib/evrone/ci/worker/consumers/jobs_consumer.rb
evrone-ci-worker-0.2.0.pre0	lib/evrone/ci/worker/consumers/jobs_consumer.rb