moquette-io / moquette

Java MQTT lightweight broker
http://moquette-io.github.io/moquette/
Apache License 2.0
2.3k stars 818 forks source link

Update message expiry remaining time and drop queued messages if expired #823

Closed andsel closed 6 months ago

andsel commented 6 months ago

Release notes

Update the message expiry property remaining seconds when a publish is forwarded. Updates SerDes for segmented queues to store also the message expiry value.

What does this PR do?

Updates the message expiry property, during forwarding of a publish, with the remaining seconds before expire. This is done after extract a message from the Session's queue and before composing the publish message to forward.

Why is it important/What is the impact to the user?

Completes the management of the message expiry property

Checklist

Related issues