|
|
@@ -21,6 +21,7 @@ namespace DotNetCore.CAP |
|
|
|
FailedRetryInterval = 60; |
|
|
|
FailedRetryCount = 50; |
|
|
|
ConsumerThreadCount = 1; |
|
|
|
ProducerThreadCount = 1; |
|
|
|
Extensions = new List<ICapOptionsExtension>(); |
|
|
|
Version = "v1"; |
|
|
|
DefaultGroup = "cap.queue." + Assembly.GetEntryAssembly()?.GetName().Name.ToLower(); |
|
|
@@ -67,6 +68,12 @@ namespace DotNetCore.CAP |
|
|
|
/// </summary> |
|
|
|
public int ConsumerThreadCount { get; set; } |
|
|
|
|
|
|
|
/// <summary> |
|
|
|
/// The number of producer thread connections. |
|
|
|
/// Default is 1 |
|
|
|
/// </summary> |
|
|
|
public int ProducerThreadCount { get; set; } |
|
|
|
|
|
|
|
/// <summary> |
|
|
|
/// Registers an extension that will be executed when building services. |
|
|
|
/// </summary> |
|
|
|