Browse Source

Fixed spelling error

master
yangxiaodong 7 years ago
parent
commit
7f3b8c0e2a
3 changed files with 6 additions and 6 deletions
  1. +1
    -1
      src/DotNetCore.CAP/IQueueExecutor.Publish.Base.cs
  2. +1
    -1
      src/DotNetCore.CAP/IQueueExecutor.Subscibe.cs
  3. +4
    -4
      src/DotNetCore.CAP/Processor/States/IState.Successed.cs

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

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




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

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




src/DotNetCore.CAP/Processor/States/IState.Succeeded.cs → src/DotNetCore.CAP/Processor/States/IState.Successed.cs View File

@@ -3,20 +3,20 @@ using DotNetCore.CAP.Models;


namespace DotNetCore.CAP.Processor.States namespace DotNetCore.CAP.Processor.States
{ {
public class SucceededState : IState
public class SuccessedState : IState
{ {
public const string StateName = "Succeeded";
public const string StateName = "Successed";


public TimeSpan? ExpiresAfter { get; private set; } public TimeSpan? ExpiresAfter { get; private set; }


public string Name => StateName; public string Name => StateName;


public SucceededState()
public SuccessedState()
{ {
ExpiresAfter = TimeSpan.FromHours(1); ExpiresAfter = TimeSpan.FromHours(1);
} }


public SucceededState(int ExpireAfterSeconds)
public SuccessedState(int ExpireAfterSeconds)
{ {
ExpiresAfter = TimeSpan.FromSeconds(ExpireAfterSeconds); ExpiresAfter = TimeSpan.FromSeconds(ExpireAfterSeconds);
} }

Loading…
Cancel
Save