class

LavinMQ::MQTT::RetainStore

Inherits Reference < Object

Constants

INDEX_FILE_NAME = "index"
Log = LavinMQ::Log.for("retainstore")
MESSAGE_FILE_SUFFIX = ".msg"

Constructors

new(dir : String, replicator : Clustering::Replicator | Nil, index : LavinMQ::MQTT::TopicTree(String) = IndexTree.new, persister : Persister | Nil = nil)
Source

Instance methods

close
Source
each(subscription : String, &block : String, IO, UInt64 -> Nil) : Nil
Source
retain(packet : Protocol::Publish) : Nil
Source

Nested types