yangxiaodong 7 anni fa
parent
commit
04572d3810
3 ha cambiato i file con 6 aggiunte e 6 eliminazioni
  1. +4
    -4
      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

+ 4
- 4
src/DotNetCore.CAP/CAP.Options.cs Vedi File

@@ -23,7 +23,7 @@ namespace DotNetCore.CAP
/// <summary>
/// Default successed message expriation timespan, in seconds.
/// </summary>
public const int DefaultSuccessMessageExpirationTimeSpan = 3600;
public const int DefaultSuccessMessageExpirationAfter = 3600;

/// <summary>
/// Failed message retry waiting interval.
@@ -34,7 +34,7 @@ namespace DotNetCore.CAP
{
PollingDelay = DefaultPollingDelay;
QueueProcessorCount = DefaultQueueProcessorCount;
SuccessedMessageExpiredTimeSpan = DefaultSuccessMessageExpirationTimeSpan;
SuccessedMessageExpiredAfter = DefaultSuccessMessageExpirationAfter;
FailedMessageWaitingInterval = DefaultFailedMessageWaitingInterval;
Extensions = new List<ICapOptionsExtension>();
}
@@ -52,10 +52,10 @@ namespace DotNetCore.CAP
public int QueueProcessorCount { get; set; }

/// <summary>
/// Sent or received successed message due timespan, then the message will be deleted at due time.
/// Sent or received successed message after timespan of due, then the message will be deleted at due time.
/// Dafault is 3600 seconds.
/// </summary>
public int SuccessedMessageExpiredTimeSpan { get; set; }
public int SuccessedMessageExpiredAfter { get; set; }

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


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

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



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

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



Caricamento…
Annulla
Salva