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