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