检测服务关闭～

2025-05-26 14:16:27 +08:00 · 2025-05-26 14:16:27 +08:00 · 433982c75b
parent f59bf4fa15
commit 433982c75b
1 changed files with 2 additions and 0 deletions
--- a/internal/server/wechat_notify_consumer.go
+++ b/internal/server/wechat_notify_consumer.go
@ -167,6 +167,8 @@ func (w *WechatNotifyConsumer) Stop(_ context.Context) error {
 	//shutdown之间，保证正在处理的消费先提交
 	_ = w.blockWaitFinish()

+	fmt.Println("关闭 wechat consumer 完成")
+
 	return nil
 }