Browse Source

rename

master
yangxiaodong 7 years ago
parent
commit
9b9a4499b7
3 changed files with 7 additions and 7 deletions
  1. +5
    -5
      src/DotNetCore.CAP/CAP.Options.cs
  2. +1
    -1
      src/DotNetCore.CAP/IQueueExecutor.Publish.Base.cs
  3. +1
    -1
      src/DotNetCore.CAP/IQueueExecutor.Subscibe.cs

+ 5
- 5
src/DotNetCore.CAP/CAP.Options.cs View File

@@ -21,9 +21,9 @@ namespace DotNetCore.CAP
public const int DefaultQueueProcessorCount = 2;

/// <summary>
/// Default successed message expriation timespan, in seconds.
/// Default succeeded message expriation timespan, in seconds.
/// </summary>
public const int DefaultSuccessMessageExpirationAfter = 3600;
public const int DefaultSucceedMessageExpirationAfter = 3600;

/// <summary>
/// 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<ICapOptionsExtension>();
}
@@ -52,10 +52,10 @@ namespace DotNetCore.CAP
public int QueueProcessorCount { get; set; }

/// <summary>
/// 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.
/// </summary>
public int SuccessedMessageExpiredAfter { get; set; }
public int SucceedMessageExpiredAfter { get; set; }

/// <summary>
/// Failed messages polling delay time.


+ 1
- 1
src/DotNetCore.CAP/IQueueExecutor.Publish.Base.cs View File

@@ -58,7 +58,7 @@ namespace DotNetCore.CAP
}
else
{
newState = new SuccessedState(_options.SuccessedMessageExpiredAfter);
newState = new SucceededState(_options.SucceedMessageExpiredAfter);
}
await _stateChanger.ChangeStateAsync(message, newState, connection);



+ 1
- 1
src/DotNetCore.CAP/IQueueExecutor.Subscibe.cs View File

@@ -64,7 +64,7 @@ namespace DotNetCore.CAP
}
else
{
newState = new SuccessedState(_options.SuccessedMessageExpiredAfter);
newState = new SucceededState(_options.SucceedMessageExpiredAfter);
}
await _stateChanger.ChangeStateAsync(message, newState, connection);



Loading…
Cancel
Save