Skip to content

Commit 3ce2d02

Browse files
committed
fix: 增加 PublishAsync 和 SubscribeAsync 的日誌詳細資訊
1 parent 1c759ef commit 3ce2d02

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

src/Netcorext.Mediator.Queuing.Redis/RedisQueuing.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,7 @@ internal async Task<string> PublishAsync(string key, Message message, Cancellati
9292
stopwatch.Stop();
9393

9494
if (stopwatch.ElapsedMilliseconds > Options.SlowCommandTimes)
95-
_logger.LogWarning("'{Name}' processing too slow, elapsed: {StopwatchElapsed}", nameof(PublishAsync), stopwatch.Elapsed);
95+
_logger.LogWarning("'{Name}' processing too slow, elapsed: {StopwatchElapsed}, key: {Key}", nameof(PublishAsync)stopwatch.Elapsed, key);
9696
}
9797
}
9898

@@ -117,7 +117,7 @@ public Task SubscribeAsync(string[] channels, Action<string, object> handler, Ca
117117
stopwatch.Stop();
118118

119119
if (stopwatch.ElapsedMilliseconds > Options.SlowCommandTimes)
120-
_logger.LogWarning("'{Name}' processing too slow, elapsed: {StopwatchElapsed}", nameof(SubscribeAsync), stopwatch.Elapsed);
120+
_logger.LogWarning("'{Name}' processing too slow, elapsed: {StopwatchElapsed}, channels: {Channels}", nameof(SubscribeAsync), stopwatch.Elapsed, string.Join(' ', channels));
121121
}
122122

123123
return Task.CompletedTask;

0 commit comments

Comments
 (0)