Created adapter layer to use Segmented queues

moquette-io / moquette

Java MQTT lightweight broker

http://moquette-io.github.io/moquette/

Apache License 2.0

2.27k stars 814 forks source link

Created adapter layer to use Segmented queues #704

Closed andsel closed 1 year ago

andsel commented 1 year ago

What the PR does

Wraps the segmented queues into session queues. This storage engine could b enabled with configuration persistent_queue_type setting, which accepts h2 or segmented, defaulting to segmented if option is not specified. Added close method to session registry to flush all the meta information that compose checkpoint file of segmented queues.

andsel commented 1 year ago

@hylkevds with this PR the segmented queues are usable from the broker.