moquette-io / moquette

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

Implements serialization and deserialization for Subscription in H2 #805

Closed andsel closed 8 months ago

andsel commented 9 months ago

Release notes

Update H2 storage to persist and reload subscription identifiers for shared and non-shared subscriptions.

What does this PR do?

Adds subscription identifier to SubscriptionRequest, SharedSubscription classes. Updates H2SubscriptionsRepository to persists and reload subscription identifier for shared and non-shared subscriptions. Updates CTrieSubscriptionDirectory to store subscription identifier contained in SharedSubscription into the H2 storage.

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

Permit to the subscription identifier to resists to broker restarts.

Checklist

How to test this PR locally

Related issues