Class PersistenceSettings.AtLeastOnceDeliverySettings
TBD
Inherited Members
Namespace: Akka.Persistence
Assembly: Akka.Persistence.dll
Syntax
public sealed class AtLeastOnceDeliverySettingsConstructors
| Improve this Doc View SourceAtLeastOnceDeliverySettings(Config)
TBD
Declaration
public AtLeastOnceDeliverySettings(Config config)Parameters
| Type | Name | Description |
|---|---|---|
| Config | config | TBD |
AtLeastOnceDeliverySettings(TimeSpan, Int32, Int32, Int32)
TBD
Declaration
public AtLeastOnceDeliverySettings(TimeSpan redeliverInterval, int redeliveryBurstLimit, int warnAfterNumberOfUnconfirmedAttempts, int maxUnconfirmedMessages)Parameters
| Type | Name | Description |
|---|---|---|
| TimeSpan | redeliverInterval | TBD |
| Int32 | redeliveryBurstLimit | TBD |
| Int32 | warnAfterNumberOfUnconfirmedAttempts | TBD |
| Int32 | maxUnconfirmedMessages | TBD |
Properties
| Improve this Doc View SourceMaxUnconfirmedMessages
Maximum number of unconfirmed messages, that this actor is allowed to hold in the memory. When this number is exceed, Deliver(ActorPath, Func<Int64, Object>, Boolean) will throw MaxUnconfirmedMessagesExceededException instead of accepting messages.
Declaration
public int MaxUnconfirmedMessages { get; }Property Value
| Type | Description |
|---|---|
| Int32 |
RedeliverInterval
Interval between redelivery attempts.
Declaration
public TimeSpan RedeliverInterval { get; }Property Value
| Type | Description |
|---|---|
| TimeSpan |
RedeliveryBurstLimit
Maximum number of unconfirmed messages that will be sent at each redelivery burst. This is to help to prevent overflowing amount of messages to be sent at once, for eg. when destination cannot be reached for a long time.
Declaration
public int RedeliveryBurstLimit { get; }Property Value
| Type | Description |
|---|---|
| Int32 |
WarnAfterNumberOfUnconfirmedAttempts
After this number of delivery attempts a UnconfirmedWarning message will be sent to Self. The count is reset after restart.
Declaration
public int WarnAfterNumberOfUnconfirmedAttempts { get; }Property Value
| Type | Description |
|---|---|
| Int32 |
Methods
| Improve this Doc View SourceWithMaxUnconfirmedMessages(Int32)
TBD
Declaration
public PersistenceSettings.AtLeastOnceDeliverySettings WithMaxUnconfirmedMessages(int maxUnconfirmedMessages)Parameters
| Type | Name | Description |
|---|---|---|
| Int32 | maxUnconfirmedMessages | TBD |
Returns
| Type | Description |
|---|---|
| PersistenceSettings.AtLeastOnceDeliverySettings | TBD |
WithRedeliverInterval(TimeSpan)
TBD
Declaration
public PersistenceSettings.AtLeastOnceDeliverySettings WithRedeliverInterval(TimeSpan redeliverInterval)Parameters
| Type | Name | Description |
|---|---|---|
| TimeSpan | redeliverInterval | TBD |
Returns
| Type | Description |
|---|---|
| PersistenceSettings.AtLeastOnceDeliverySettings | TBD |
WithRedeliveryBurstLimit(Int32)
TBD
Declaration
public PersistenceSettings.AtLeastOnceDeliverySettings WithRedeliveryBurstLimit(int redeliveryBurstLimit)Parameters
| Type | Name | Description |
|---|---|---|
| Int32 | redeliveryBurstLimit | TBD |
Returns
| Type | Description |
|---|---|
| PersistenceSettings.AtLeastOnceDeliverySettings | TBD |
WithUnconfirmedAttemptsToWarn(Int32)
TBD
Declaration
public PersistenceSettings.AtLeastOnceDeliverySettings WithUnconfirmedAttemptsToWarn(int unconfirmedAttemptsToWarn)Parameters
| Type | Name | Description |
|---|---|---|
| Int32 | unconfirmedAttemptsToWarn | TBD |
Returns
| Type | Description |
|---|---|
| PersistenceSettings.AtLeastOnceDeliverySettings | TBD |
Improve this Doc