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