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