Skip to content

Commit 7cd5620

Browse files
committed
fix
1 parent 2bd826d commit 7cd5620

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

‎Cyaim.WebSocketServer/Cluster/Cyaim.WebSocketServer.Cluster.Hybrid.MessageQueue.RabbitMQ/RabbitMQMessageQueueService.cs‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -108,18 +108,18 @@ public async Task ConnectAsync()
108108
// RabbitMQ.Client 7.0+ uses async event handlers / RabbitMQ.Client 7.0+ 使用异步事件处理器
109109
_connection.ConnectionShutdownAsync += (sender, args) =>
110110
{
111-
_logger.LogError($"[RabbitMQMessageQueueService] 检测到连接关闭事件 - Reason: {args?.Reason}, ReplyCode: {args?.ReplyCode}, ReplyText: {args?.ReplyText}");
111+
_logger.LogError($"[RabbitMQMessageQueueService] 检测到连接关闭事件 - ReplyCode: {args?.ReplyCode}, ReplyText: {args?.ReplyText}");
112112
// Clear consumers as they are no longer valid / 清除消费者,因为它们不再有效
113113
_consumers.Clear();
114114
return Task.CompletedTask;
115115
};
116116

117117
_channel.ChannelShutdownAsync += (sender, args) =>
118118
{
119-
_logger.LogError($"[RabbitMQMessageQueueService] 检测到通道关闭事件 - Reason: {args?.Reason}, ReplyCode: {args?.ReplyCode}, ReplyText: {args?.ReplyText}");
119+
_logger.LogError($"[RabbitMQMessageQueueService] 检测到通道关闭事件 - ReplyCode: {args?.ReplyCode}, ReplyText: {args?.ReplyText}");
120120
// Clear consumers as they are no longer valid / 清除消费者,因为它们不再有效
121121
_consumers.Clear();
122-
122+
123123
// Trigger reconnection in background / 在后台触发重新连接
124124
_ = Task.Run(async () =>
125125
{

0 commit comments

Comments
 (0)