From d74d15ef1a49c43b704095445b1290ce116e220e Mon Sep 17 00:00:00 2001
From: Savorboard <yangxiaodong1214@126.com>
Date: Mon, 30 Nov 2020 18:22:34 +0800
Subject: [PATCH] =?UTF-8?q?Support=20custom=20multiple=20producer=20thread?=
 =?UTF-8?q?s=20for=20sending=E3=80=82=20#731?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/DotNetCore.CAP/CAP.Options.cs | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/src/DotNetCore.CAP/CAP.Options.cs b/src/DotNetCore.CAP/CAP.Options.cs
index ebdbf91..2990a36 100644
--- a/src/DotNetCore.CAP/CAP.Options.cs
+++ b/src/DotNetCore.CAP/CAP.Options.cs
@@ -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>