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

change：cap不打印超时日志

Browse Source
This commit is contained in:
李鹏军 2024-04-22 09:06:45 +08:00
parent f78d463a68
commit 954654ede6
2 changed files with 24 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
.idea/.idea.SJZY.Track.Api/.idea/.gitignore generated vendored Normal file
View File

@ -0,0 +1,13 @@
# Default ignored files
/shelf/
/workspace.xml
# Rider ignored files
/projectSettingsUpdater.xml
/.idea.SJZY.Track.Api.iml
/modules.xml
/contentModel.xml
# Editor-based HTTP Client requests
/httpRequests/
# Datasource local storage ignored files
/dataSources/
/dataSources.local.xml

22
src/SJZY.Track.Application/EventHandlers/CAPFilter.cs
View File

@ -57,12 +57,12 @@ public class CapFilter : SubscribeFilter
/// <returns></returns> /// <returns></returns>
public override Task OnSubscribeExecutedAsync(ExecutedContext context) public override Task OnSubscribeExecutedAsync(ExecutedContext context)
{ {
context.DeliverMessage.Headers.TryGetValue("sjzy-receive-time", out var receiveTime); // context.DeliverMessage.Headers.TryGetValue("sjzy-receive-time", out var receiveTime);
context.DeliverMessage.Headers.TryGetValue("cap-msg-name", out var receiveName); // context.DeliverMessage.Headers.TryGetValue("cap-msg-name", out var receiveName);
context.DeliverMessage.Headers.TryGetValue("sjzy-arguments", out var arguments); // context.DeliverMessage.Headers.TryGetValue("sjzy-arguments", out var arguments);
context.DeliverMessage.Headers.TryGetValue("cap-msg-id", out var messageId); // context.DeliverMessage.Headers.TryGetValue("cap-msg-id", out var messageId);
//
BuildLog(receiveTime!, receiveName!, arguments!, false, messageId!); // BuildLog(receiveTime!, receiveName!, arguments!, false, messageId!);
return Task.CompletedTask; return Task.CompletedTask;
} }
@ -86,11 +86,11 @@ public class CapFilter : SubscribeFilter
LogHelper.Error($"cap-msg-id：{messageId}\n{context.Exception}"); LogHelper.Error($"cap-msg-id：{messageId}\n{context.Exception}");
context.DeliverMessage.Headers.TryGetValue("sjzy-receive-time", out var receiveTime); // context.DeliverMessage.Headers.TryGetValue("sjzy-receive-time", out var receiveTime);
context.DeliverMessage.Headers.TryGetValue("cap-msg-name", out var receiveName); // context.DeliverMessage.Headers.TryGetValue("cap-msg-name", out var receiveName);
context.DeliverMessage.Headers.TryGetValue("sjzy-arguments", out var arguments); // context.DeliverMessage.Headers.TryGetValue("sjzy-arguments", out var arguments);
//
BuildLog(receiveTime!, receiveName!, arguments, true, messageId!); // BuildLog(receiveTime!, receiveName!, arguments, true, messageId!);
return Task.CompletedTask; return Task.CompletedTask;
} }