class

LavinMQ::MQTT::SessionMessageStore

Inherits LavinMQ::MessageStore < Reference < Object

A session's message store, which also holds the packet ids of the messages the session owes a resuming client. The ids live here so that a message leaving the store takes its id with it, whichever path removed it.

Instance methods

delete(sp) : Nil

Source

forget_packet_id(sp : SegmentPosition) : Nil

Source

packet_id?(sp : SegmentPosition) : UInt16 | Nil

Source

remember_packet_id(sp : SegmentPosition, packet_id : UInt16) : Nil

Source