From 5b12642faf9199cee7bf66166aed6c45491af28c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E9=B9=8F=E5=86=9B?= <2357729423@qq.com>
Date: Thu, 9 May 2024 17:49:33 +0800
Subject: [PATCH 1/2] =?UTF-8?q?change=EF=BC=9Acap=E5=BC=82=E6=AD=A5?=
=?UTF-8?q?=E4=B8=8D=E6=89=93=E6=B6=88=E6=81=AF=E5=86=85=E5=AE=B9=EF=BC=88?=
=?UTF-8?q?=E5=8E=BBcap=E7=9C=8B=EF=BC=89?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
src/SJZY.Track.Application/SjzyTrackApplicationModule.cs | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/src/SJZY.Track.Application/SjzyTrackApplicationModule.cs b/src/SJZY.Track.Application/SjzyTrackApplicationModule.cs
index ff8ecefe..59827ae9 100644
--- a/src/SJZY.Track.Application/SjzyTrackApplicationModule.cs
+++ b/src/SJZY.Track.Application/SjzyTrackApplicationModule.cs
@@ -107,8 +107,7 @@ namespace SJZY.Track.Application
LogHelper.Error($@"
|-CAP失败回调事件：
|-处理类型：{(faileCalback.MessageType == DotNetCore.CAP.Messages.MessageType.Subscribe ? "消费消息达到最大重试次数，需要开发人员介入" : "生产消息推送失败")}
- |-头部信息：{faileCalback.Message.Headers.ToJson()}
- |-消息内容：{(faileCalback.Message.Value is string ? faileCalback.Message.Value : faileCalback.Message.Value?.ToJson())}");
+ |-头部信息：{faileCalback.Message.Headers.ToJson()}");
}
catch (Exception ex)
{
From 7482521e7553eacb3cbd6f58350b49e0a8825a21 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E9=B9=8F=E5=86=9B?= <2357729423@qq.com>
Date: Sat, 11 May 2024 10:13:00 +0800
Subject: [PATCH 2/2] =?UTF-8?q?opt=EF=BC=9A=E5=8D=87=E7=BA=A7cap=E5=88=B08?=
=?UTF-8?q?.1.2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
src/SJZY.Track.Application/SJZY.Track.Application.csproj | 8 ++++----
src/SJZY.Track.Application/SjzyTrackApplicationModule.cs | 4 +---
2 files changed, 5 insertions(+), 7 deletions(-)
diff --git a/src/SJZY.Track.Application/SJZY.Track.Application.csproj b/src/SJZY.Track.Application/SJZY.Track.Application.csproj
index f9d34258..b2801d4a 100644
--- a/src/SJZY.Track.Application/SJZY.Track.Application.csproj
+++ b/src/SJZY.Track.Application/SJZY.Track.Application.csproj
@@ -17,10 +17,10 @@
-
-
-
-
+
+
+
+
diff --git a/src/SJZY.Track.Application/SjzyTrackApplicationModule.cs b/src/SJZY.Track.Application/SjzyTrackApplicationModule.cs
index 59827ae9..2984ac45 100644
--- a/src/SJZY.Track.Application/SjzyTrackApplicationModule.cs
+++ b/src/SJZY.Track.Application/SjzyTrackApplicationModule.cs
@@ -89,10 +89,8 @@ namespace SJZY.Track.Application
// options.TopicNamePrefix = "v1";
options.FailedRetryInterval = configuration.GetValue("CAP:FailedRetryInterval");
options.FailedRetryCount = configuration.GetValue("CAP:FailedRetryCount");
- options.ConsumerThreadCount = configuration.GetValue("CAP:ConsumerThreadCount");
options.SucceedMessageExpiredAfter = configuration.GetValue("CAP:SucceedMessageExpiredAfter");
- options.UseDispatchingPerGroup = configuration.GetValue("CAP:UseDispatchingPerGroup");
- options.EnableConsumerPrefetch = true;
+ options.EnableSubscriberParallelExecute = true;
options.UseDashboard(dashboardOptions =>
{