Skip to content

Commit d74d15e

Browse files
committed
Support custom multiple producer threads for sending。 #731
1 parent 3528432 commit d74d15e

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

src/DotNetCore.CAP/CAP.Options.cs

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@ public CapOptions()
2121
FailedRetryInterval = 60;
2222
FailedRetryCount = 50;
2323
ConsumerThreadCount = 1;
24+
ProducerThreadCount = 1;
2425
Extensions = new List<ICapOptionsExtension>();
2526
Version = "v1";
2627
DefaultGroup = "cap.queue." + Assembly.GetEntryAssembly()?.GetName().Name.ToLower();
@@ -67,6 +68,12 @@ public CapOptions()
6768
/// </summary>
6869
public int ConsumerThreadCount { get; set; }
6970

71+
/// <summary>
72+
/// The number of producer thread connections.
73+
/// Default is 1
74+
/// </summary>
75+
public int ProducerThreadCount { get; set; }
76+
7077
/// <summary>
7178
/// Registers an extension that will be executed when building services.
7279
/// </summary>

0 commit comments

Comments
 (0)