Class: Nsqrb::Frame::Message
- Inherits:
-
Nsqrb::Frame
- Object
- OpenStruct
- Nsqrb::Frame
- Nsqrb::Frame::Message
- Defined in:
- lib/nsqrb/frame/message.rb
Instance Method Summary collapse
-
#initialize(frame) ⇒ Message
constructor
A new instance of Message.
Constructor Details
#initialize(frame) ⇒ Message
Returns a new instance of Message.
4 5 6 7 |
# 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 |