module PikaQue::Worker
Public Class Methods
included(base)
click to toggle source
# File lib/pika_que/worker.rb, line 45 def self.included(base) base.extend ClassMethods end
new(opts = {})
click to toggle source
# File lib/pika_que/worker.rb, line 6 def initialize(opts = {}) @subscriber = PikaQue::Subscriber.new(opts.merge(self.class.local_config || {})) end
Public Instance Methods
ack!()
click to toggle source
# File lib/pika_que/worker.rb, line 33 def ack!; :ack end
consumer_arguments()
click to toggle source
# File lib/pika_que/worker.rb, line 41 def consumer_arguments self.class.priority.nil? ? {} : { :'x-priority' => self.class.priority } end
logger()
click to toggle source
# File lib/pika_que/worker.rb, line 37 def logger PikaQue.logger end
prepare()
click to toggle source
# File lib/pika_que/worker.rb, line 10 def prepare @subscriber.setup_queue(self.class.queue_name, self.class.queue_opts) @subscriber.setup_handler(self.class.handler_class, self.class.handler_opts) end
reject!()
click to toggle source
# File lib/pika_que/worker.rb, line 34 def reject!; :reject; end
requeue!()
click to toggle source
# File lib/pika_que/worker.rb, line 35 def requeue!; :requeue; end
run()
click to toggle source
# File lib/pika_que/worker.rb, line 15 def run @subscriber.subscribe(self) end
start()
click to toggle source
# File lib/pika_que/worker.rb, line 19 def start prepare run end
stop()
click to toggle source
# File lib/pika_que/worker.rb, line 24 def stop @subscriber.unsubscribe @subscriber.teardown end
work(delivery_info, metadata, msg)
click to toggle source
# File lib/pika_que/worker.rb, line 29 def work(delivery_info, metadata, msg) perform(msg) end