on Shard Pick Up Failure
Called if an Exception
occurred when the Delivery
attempted to pick up a shard.
Please note, this callback is not invoked in case the shard cannot be picked up if it's already picked up by another worker. It is so, because such a use case is a part of normal flow, and thus does not provoke a RuntimeException
.
Returns an action to take in relation to the failure.
By default this callback returns an Action that propagates the occurred exception. This means the occurred exception will be throw out of the deliverMessagesFrom() method.
Parameters
failure
contains an information about the occurred failure and gives access to predefined Action
s to handle the error