Class: Nsqrb::Frame::Message

Inherits:

Nsqrb::Frame

• Object
• OpenStruct
• Nsqrb::Frame
• Nsqrb::Frame::Message

Defined in:

lib/nsqrb/frame/message.rb

Instance Method Summary

• #initialize(frame) ⇒ Message constructor

  A new instance of Message.

Constructor Details

#initialize(frame) ⇒ Message

Returns a new instance of Message.

# 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