AtLeastOnceDeliveryActor Properties |
The AtLeastOnceDeliveryActor type exposes the following members.
Name | Description | |
---|---|---|
Extension |
TBD
(Inherited from Eventsourced.) | |
InternalStashOverflowStrategy |
TBD
(Inherited from Eventsourced.) | |
IsRecovering |
Returns true if this persistent entity is currently recovering.
(Inherited from Eventsourced.) | |
IsRecoveryFinished |
Returns true if this persistent entity has successfully finished recovery.
(Inherited from Eventsourced.) | |
Journal |
TBD
(Inherited from Eventsourced.) | |
JournalPluginId |
TBD
(Inherited from Eventsourced.) | |
LastSequenceNr |
Highest received sequence number so far or `0L` if this actor
hasn't replayed or stored any persistent events yet.
(Inherited from Eventsourced.) | |
Log |
TBD
(Inherited from Eventsourced.) | |
MaxUnconfirmedMessages |
Maximum number of unconfirmed messages, that this actor is allowed to hold in the memory.
if this number is exceeded, Deliver(ActorPath, FuncInt64, Object, Boolean) will not accept more
messages and it will throw MaxUnconfirmedMessagesExceededException.
The default value can be configure with the 'akka.persistence.at-least-once-delivery.max-unconfirmed-messages'
configuration key. This method can be overridden by implementation classes to return
non-default values.
| |
PersistenceId |
Id of the persistent entity for which messages should be replayed.
(Inherited from Eventsourced.) | |
Recovery |
Called when the persistent actor is started for the first time.
The returned Recovery object defines how the actor
will recover its persistent state before handling the first incoming message.
To skip recovery completely return None.
(Inherited from Eventsourced.) | |
RedeliverInterval |
Interval between redelivery attempts.
The default value can be configure with the 'akka.persistence.at-least-once-delivery.redeliver-interval'
configuration key. This method can be overridden by implementation classes to return
non-default values.
| |
RedeliveryBurstLimit |
Maximum number of unconfirmed messages that will be sent at each redelivery burst
(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 prevent an overwhelming amount of messages to be sent at once.
The default value can be configure with the 'akka.persistence.at-least-once-delivery.redelivery-burst-limit'
configuration key. This method can be overridden by implementation classes to return
non-default values.
| |
Self |
Gets the self ActorRef
(Inherited from ActorBase.) | |
Sender |
Gets the sending ActorRef of the current message
(Inherited from ActorBase.) | |
SnapshotPluginId |
TBD
(Inherited from Eventsourced.) | |
SnapshotSequenceNr |
Returns LastSequenceNr (Inherited from Eventsourced.) | |
SnapshotStore |
TBD
(Inherited from Eventsourced.) | |
SnapshotterId |
Returns PersistenceId.
(Inherited from Eventsourced.) | |
Stash |
TBD
(Inherited from Eventsourced.) | |
UnconfirmedCount |
Number of messages that have not been confirmed yet.
| |
WarnAfterNumberOfUnconfirmedAttempts |
After this number of delivery attempts a UnconfirmedWarning message will be sent to
Self. The count is reset after restart.
The default value can be configure with the 'akka.persistence.at-least-once-delivery.warn-after-number-of-unconfirmed-attempts'
configuration key. This method can be overridden by implementation classes to return
non-default values.
|