diff --git a/src/DotNetCore.CAP/CAP.Options.cs b/src/DotNetCore.CAP/CAP.Options.cs
index d6cd441..c3a1290 100644
--- a/src/DotNetCore.CAP/CAP.Options.cs
+++ b/src/DotNetCore.CAP/CAP.Options.cs
@@ -21,9 +21,9 @@ namespace DotNetCore.CAP
public const int DefaultQueueProcessorCount = 2;
///
- /// Default successed message expriation timespan, in seconds.
+ /// Default succeeded message expriation timespan, in seconds.
///
- public const int DefaultSuccessMessageExpirationAfter = 3600;
+ public const int DefaultSucceedMessageExpirationAfter = 3600;
///
/// Failed message retry waiting interval.
@@ -34,7 +34,7 @@ namespace DotNetCore.CAP
{
PollingDelay = DefaultPollingDelay;
QueueProcessorCount = DefaultQueueProcessorCount;
- SuccessedMessageExpiredAfter = DefaultSuccessMessageExpirationAfter;
+ SucceedMessageExpiredAfter = DefaultSucceedMessageExpirationAfter;
FailedMessageWaitingInterval = DefaultFailedMessageWaitingInterval;
Extensions = new List();
}
@@ -52,10 +52,10 @@ namespace DotNetCore.CAP
public int QueueProcessorCount { get; set; }
///
- /// Sent or received successed message after timespan of due, then the message will be deleted at due time.
+ /// Sent or received succeed message after timespan of due, then the message will be deleted at due time.
/// Dafault is 3600 seconds.
///
- public int SuccessedMessageExpiredAfter { get; set; }
+ public int SucceedMessageExpiredAfter { get; set; }
///
/// Failed messages polling delay time.
diff --git a/src/DotNetCore.CAP/IQueueExecutor.Publish.Base.cs b/src/DotNetCore.CAP/IQueueExecutor.Publish.Base.cs
index d415e11..128b9b7 100644
--- a/src/DotNetCore.CAP/IQueueExecutor.Publish.Base.cs
+++ b/src/DotNetCore.CAP/IQueueExecutor.Publish.Base.cs
@@ -58,7 +58,7 @@ namespace DotNetCore.CAP
}
else
{
- newState = new SuccessedState(_options.SuccessedMessageExpiredAfter);
+ newState = new SucceededState(_options.SucceedMessageExpiredAfter);
}
await _stateChanger.ChangeStateAsync(message, newState, connection);
diff --git a/src/DotNetCore.CAP/IQueueExecutor.Subscibe.cs b/src/DotNetCore.CAP/IQueueExecutor.Subscibe.cs
index f6e08af..c043379 100644
--- a/src/DotNetCore.CAP/IQueueExecutor.Subscibe.cs
+++ b/src/DotNetCore.CAP/IQueueExecutor.Subscibe.cs
@@ -64,7 +64,7 @@ namespace DotNetCore.CAP
}
else
{
- newState = new SuccessedState(_options.SuccessedMessageExpiredAfter);
+ newState = new SucceededState(_options.SucceedMessageExpiredAfter);
}
await _stateChanger.ChangeStateAsync(message, newState, connection);