Fix/segment persistent queues

moquette-io / moquette

Java MQTT lightweight broker

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

Apache License 2.0

2.3k stars 818 forks source link

Closed hylkevds closed 1 year ago

hylkevds commented 1 year ago

This PR builds on #724, #728 and #722 and contains further fixes from #716:

Make a copy of the message buffer (one for each command thread) so access patterns don't interfere across threads

andsel commented 1 year ago

@hylkevds please can you fix the conflicts realigning to the current main so that we can merge it? :pray: