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 ff8ecefe..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 =>
{
@@ -107,8 +105,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)
{