module Sneakers::Worker::ClassMethods
Attributes
queue_name[R]
queue_opts[R]
Public Instance Methods
enqueue(msg, opts={})
click to toggle source
# File lib/sneakers/worker.rb, line 142 def enqueue(msg, opts={}) opts[:routing_key] ||= @queue_opts[:routing_key] opts[:content_type] ||= @queue_opts[:content_type] opts[:to_queue] ||= @queue_name publisher.publish(msg, opts) end
from_queue(q, opts={})
click to toggle source
# File lib/sneakers/worker.rb, line 137 def from_queue(q, opts={}) @queue_name = q.to_s @queue_opts = opts end
Private Instance Methods
publisher()
click to toggle source
# File lib/sneakers/worker.rb, line 152 def publisher @publisher ||= Sneakers::Publisher.new(queue_opts) end