raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Merge pull request #16386 from adamw/wip-16348-limit-alod-adamw

Browse source 
+per #16348 Limit the number of messages redelivered at each interval
This commit is contained in:
Roland Kuhn 2014-12-01 13:04:38 +01:00
commit 3cf00cecb1
6 changed files with 80 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-docs/rst/java/persistence.rst
View file

@ -456,6 +456,13 @@ The interval between redelivery attempts is defined by the ``redeliverInterval``
The default value can be configured with the ``akka.persistence.at-least-once-delivery.redeliver-interval``
configuration key. The method can be overridden by implementation classes to return non-default values.
The maximum number of messages that will be sent at each redelivery burst is defined by the
``redeliveryBurstLimit`` method (burst frequency is half of the redelivery interval). If there's a lot of
unconfirmed messages (e.g. if the destination is not available for a long time), this helps to prevent an overwhelming
amount of messages to be sent at once. The default value can be configured with the
``akka.persistence.at-least-once-delivery.redelivery-burst-limit`` configuration key. The method can be overridden
by implementation classes to return non-default values.
After a number of delivery attempts a ``AtLeastOnceDelivery.UnconfirmedWarning`` message
will be sent to ``self``. The re-sending will still continue, but you can choose to call
``confirmDelivery`` to cancel the re-sending. The number of delivery attempts before emitting the