class Nsque::Producer
Attributes
messages_count[R]
Public Class Methods
new(options = {})
click to toggle source
# File lib/nsque/producer.rb, line 5 def initialize(options = {}) @producer = Nsqrb::Producer.new(options[:host], options[:port], options[:topic]) @messages_count = 0 end
Public Instance Methods
reset_counters()
click to toggle source
# File lib/nsque/producer.rb, line 16 def reset_counters @messages_count = 0 end
write(item)
click to toggle source
# File lib/nsque/producer.rb, line 10 def write(item) message = JSON.generate(item) @producer.post!(message) @messages_count += 1 end