Click or drag to resize
Akka.NETAtLeastOnceDeliverySemantic Class
TBD
Inheritance Hierarchy
SystemObject
  Akka.PersistenceAtLeastOnceDeliverySemantic

Namespace:  Akka.Persistence
Assembly:  Akka.Persistence (in Akka.Persistence.dll) Version: 1.2.3.42 (1.2.3.42)
Syntax
public class AtLeastOnceDeliverySemantic

The AtLeastOnceDeliverySemantic type exposes the following members.

Constructors
  NameDescription
Public methodAtLeastOnceDeliverySemantic
Initializes a new instance of the AtLeastOnceDeliverySemantic class.
Top
Properties
  NameDescription
Public propertyMaxUnconfirmedMessages
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.
Public propertyRedeliverInterval
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.
Public propertyRedeliveryBurstLimit
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.
Public propertyUnconfirmedCount
Number of messages, that have not been confirmed yet.
Public propertyWarnAfterNumberOfUnconfirmedAttempts
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.
Top
Methods
  NameDescription
Public methodAroundReceive
TBD
Public methodCancel
TBD
Public methodConfirmDelivery
Call this method when a message has been confirmed by the destination, or to abort re-sending.
Public methodDeliver
TBD
Public methodEquals
Determines whether the specified object is equal to the current object.
(Inherited from Object.)
Protected methodFinalize
Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection.
(Inherited from Object.)
Public methodGetDeliverySnapshot
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.
Public methodGetHashCode
Serves as the default hash function.
(Inherited from Object.)
Public methodGetType
Gets the Type of the current instance.
(Inherited from Object.)
Protected methodMemberwiseClone
Creates a shallow copy of the current Object.
(Inherited from Object.)
Public methodOnReplaySuccess
TBD
Public methodSetDeliverySnapshot
If snapshot from GetDeliverySnapshot was saved it will be received during recovery phase in a SnapshotOffer message and should be set with this method.
Public methodToString
Returns a string that represents the current object.
(Inherited from Object.)
Top
Extension Methods
See Also