module IvoryTower::Consumer

Public Instance Methods

job_id() click to toggle source
# File lib/ivory_tower/consumer.rb, line 14
def job_id
  @job_id ||= SecureRandom.hex
end
run(options = nil) click to toggle source
# File lib/ivory_tower/consumer.rb, line 6
def run(options = nil)
  queue.subscribe_options = options if options

  queue.consume do |message|
    consume(message)
  end
end