Akka.Persistence.Extras
Akka.Persistence.Extras copied to clipboard
Rewrite AtLeastOnceDeliverySemantic
Major changes needed:
- Remove
ImmutableDictionary<T>
in favor ofDictionary<T>
- if the semantic isn't accessed concurrently, then it's not needed. - Add ability to add single
UnconfirmedDelivery
messages to theAtLeastOnceDelivery
state incrementally, so these items can be retrieved viaRecover<UnconfirmedDelivery>
.