From b98742f4319ddddf487c485a9b40efbafcb0fbd0 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E9=B9=8F=E5=86=9B?= <2357729423@qq.com>
Date: Wed, 27 Mar 2024 17:21:46 +0800
Subject: [PATCH] change remove topic prefix

---
 src/SJZY.Track.Application/SjzyTrackApplicationModule.cs | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/SJZY.Track.Application/SjzyTrackApplicationModule.cs b/src/SJZY.Track.Application/SjzyTrackApplicationModule.cs
index 28f3329c..f9f5633a 100644
--- a/src/SJZY.Track.Application/SjzyTrackApplicationModule.cs
+++ b/src/SJZY.Track.Application/SjzyTrackApplicationModule.cs
@@ -86,7 +86,7 @@ namespace SJZY.Track.Application
                     configure.Port = configuration.GetValue<int>("RabbitMQ:Port");
                 });
 
-                options.TopicNamePrefix = "v1";
+                // options.TopicNamePrefix = "v1";
                 options.SucceedMessageExpiredAfter = 6 * 60 * 60;
                 options.FailedRetryInterval = 60;
                 options.FailedRetryCount = 3;
@@ -103,8 +103,8 @@ namespace SJZY.Track.Application
                         LogHelper.Error($@"
     |-CAP失败回调事件：
     |-处理类型：{(faileCalback.MessageType == DotNetCore.CAP.Messages.MessageType.Subscribe ? "消费消息达到最大重试次数，需要开发人员介入" : "生产消息推送失败")}
-    |-头部信息：{faileCalback?.Message?.Headers?.ToJson()}
-   	|-消息内容：{((JsonElement)faileCalback?.Message?.Value).GetRawText()}");
+    |-头部信息：{faileCalback.Message.Headers.ToJson()}
+   	|-消息内容：{(faileCalback.Message.Value is string ? faileCalback.Message.Value : ((JsonElement?)faileCalback.Message.Value)?.GetRawText())}");
                     }
                     catch (Exception ex)
                     {