ideship/track
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/S02-轨迹中台第二部分' into test

Browse Source
This commit is contained in:
dingenwen 2024-03-27 17:22:36 +08:00
commit 9f3085a75b
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/SJZY.Track.Application/SjzyTrackApplicationModule.cs
View File

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