AtLeastOnceDeliverySemantic Class |
Namespace: Akka.Persistence
The AtLeastOnceDeliverySemantic type exposes the following members.
Name | Description | |
---|---|---|
AtLeastOnceDeliverySemantic |
Initializes a new instance of the AtLeastOnceDeliverySemantic class.
|
Name | Description | |
---|---|---|
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.
| |
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.
| |
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.
|
Name | Description | |
---|---|---|
AroundReceive |
TBD
| |
Cancel |
TBD
| |
ConfirmDelivery |
Call this method when a message has been confirmed by the destination,
or to abort re-sending.
| |
Deliver |
TBD
| |
Equals | Determines whether the specified object is equal to the current object. (Inherited from Object.) | |
Finalize | Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection. (Inherited from Object.) | |
GetDeliverySnapshot |
Full state of the AtLeastOnceDeliverySemantic. It can be saved with
SaveSnapshot(Object). During recovery the snapshot received in
SnapshotOffer should be set with SetDeliverySnapshot(AtLeastOnceDeliverySnapshot).
The AtLeastOnceDeliverySnapshot contains the full delivery state,
including unconfirmed messages. If you need a custom snapshot for other parts of the
actor state you must also include the AtLeastOnceDeliverySnapshot.
It is serialized using protobuf with the ordinary Akka serialization mechanism.
It is easiest to include the bytes of the AtLeastOnceDeliverySnapshot
as a blob in your custom snapshot.
| |
GetHashCode | Serves as the default hash function. (Inherited from Object.) | |
GetType | Gets the Type of the current instance. (Inherited from Object.) | |
MemberwiseClone | Creates a shallow copy of the current Object. (Inherited from Object.) | |
OnReplaySuccess |
TBD
| |
SetDeliverySnapshot |
If snapshot from GetDeliverySnapshot was saved it will be received during recovery
phase in a SnapshotOffer message and should be set with this method.
| |
ToString | Returns a string that represents the current object. (Inherited from Object.) |
Name | Description | |
---|---|---|
AsInstanceOfT |
TBD
(Defined by Extensions.) | |
Match | Overloaded.
Matches the specified target.
(Defined by PatternMatch.) | |
MatchT | Overloaded.
Matches the specified target and return a result of target processing.
(Defined by PatternMatch.) |