From 9b9a4499b739b744d67b8955dfcc30132d88ce67 Mon Sep 17 00:00:00 2001 From: yangxiaodong Date: Tue, 5 Sep 2017 18:29:26 +0800 Subject: [PATCH] rename --- src/DotNetCore.CAP/CAP.Options.cs | 10 +++++----- src/DotNetCore.CAP/IQueueExecutor.Publish.Base.cs | 2 +- src/DotNetCore.CAP/IQueueExecutor.Subscibe.cs | 2 +- 3 files changed, 7 insertions(+), 7 deletions(-) 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);