class Nsqcd::Queue

Attributes

name[R]
opts[R]
topic[R]

Public Class Methods

new(name, opts) click to toggle source
# File lib/nsqcd/queue.rb, line 4
def initialize(name, opts)
  @name = name
  @opts = opts
  @handler_klass = Nsqcd::CONFIG[:handler]
end

Public Instance Methods

publish(topic, msg) click to toggle source
# File lib/nsqcd/queue.rb, line 10
def publish(topic, msg)
  producer = Nsq::Producer.new(@opts[:nsqlookupd], topic)
  producer.write(msg)
end