module Nsqcd::Worker::ClassMethods
Attributes
channel[R]
opts[R]
topic[R]
Public Instance Methods
enqueue(msg, o={})
click to toggle source
# File lib/nsqcd/worker.rb, line 87 def enqueue(msg, o={}) @opts[:to_queue] ||= @topic publisher.publish(msg, o) end
from(o ={})
click to toggle source
# File lib/nsqcd/worker.rb, line 83 def from(o ={}) @opts = o end
Private Instance Methods
publisher()
click to toggle source
# File lib/nsqcd/worker.rb, line 94 def publisher @publisher ||= Nsqcd::Publisher.new(queue_opts) end