class Nsqrb::Command::Pub

Public Instance Methods

to_line() click to toggle source
# File lib/nsqrb/command/pub.rb, line 4
def to_line
  msg = @args[:message].to_s
  [name, ' ', @args[:topic_name], "\n", msg.length, msg].pack('a*a*a*a*l>a*')
end

Private Instance Methods

failure_codes() click to toggle source
# File lib/nsqrb/command/pub.rb, line 15
def failure_codes
  %w(E_INVALID E_BAD_TOPIC E_BAD_MESSAGE E_PUB_FAILED)
end
params() click to toggle source
# File lib/nsqrb/command/pub.rb, line 19
def params
  [:topic_name, :message]
end
success_codes() click to toggle source
# File lib/nsqrb/command/pub.rb, line 11
def success_codes
  %w(OK)
end