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