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