class Nsqrb::Frame::Message
Public Class Methods
new(frame)
click to toggle source
Calls superclass method
# File lib/nsqrb/frame/message.rb, line 4 def initialize(frame) unpacked = frame[:data].unpack("Q>s>a16a#{frame[:size]}") super(Hash[*([:timestamp, :attempts, :id, :content].zip(unpacked).flatten)]) end