LavinMQ::MQTT::Session
Inherits LavinMQ::MQTT::Subscriber < LavinMQ::AMQP::QueueStats < LavinMQ::Stats < LavinMQ::PolicyTarget < LavinMQ::SortableJSON < Reference < Object
Constants
Instance methods
This can be overriden if the child class needs to do something after a policy has been applied.
Like stats_details but without log
Called once per matching filter when an MQTT message is published.
ctx is the publishing client's scratch state, reset per publish, so a
subscriber matched by several filters can tell the calls apart from a
new publish. Returns true if the message was accepted by at least one
receiver.
Returns whether the message was accepted, so the exchange only counts deliveries that happened.
A concurrent API deletion can make the bind fail. TODO: Check session identity under the definitions lock before binding.