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