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