Sha256: 6abc9d7ba8e3b517f111660faa1ab3174ce8f7d4343643407cbc19bae5fea81f
Contents?: true
Size: 653 Bytes
Versions: 19
Compression:
Stored size: 653 Bytes
Contents
require 'evrone/common/amqp'
require 'evrone/ci/message'
module Evrone
module CI
module Worker
class JobsConsumer
include Evrone::Common::AMQP::Consumer
exchange 'ci.jobs'
queue 'ci.worker.jobs'
ack true
model Message::PerformJob
def perform(message)
Worker.logger.tagged self.class.consumer_id do
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
end
Version data entries
19 entries across 19 versions & 1 rubygems