class Vx::Worker::JobsConsumer

Public Instance Methods

perform(message) click to toggle source
# 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