Class: Vx::Worker::JobsConsumer

Inherits:
Object
  • Object
show all
Includes:
Common::AMQP::Consumer
Defined in:
lib/vx/worker/consumers/jobs_consumer.rb

Instance Method Summary collapse

Instance Method Details

#perform(message) ⇒ Object 



16
17
18
19
20
21
22
23
24
 
# File 'lib/vx/worker/consumers/jobs_consumer.rb', line 16

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