From 05784b85fec625e615f5bb1fa1736f29f05e9b12 Mon Sep 17 00:00:00 2001
From: ziming <zi__mm@163.com>
Date: Mon, 26 May 2025 14:23:06 +0800
Subject: [PATCH] =?UTF-8?q?=E6=A3=80=E6=B5=8B=E6=9C=8D=E5=8A=A1=E5=85=B3?=
 =?UTF-8?q?=E9=97=AD=EF=BD=9E?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/server/wechat_notify_consumer.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/internal/server/wechat_notify_consumer.go b/internal/server/wechat_notify_consumer.go
index 6ab885b..1bafc1b 100644
--- a/internal/server/wechat_notify_consumer.go
+++ b/internal/server/wechat_notify_consumer.go
@@ -160,6 +160,7 @@ func (w *WechatNotifyConsumer) processMessage(ctx context.Context, msg mq_http_s
 
 // Stop 停止消息消费
 func (w *WechatNotifyConsumer) Stop(_ context.Context) error {
+
 	if !w.conf.WechatNotifyMQ.IsOpenConsumer {
 		fmt.Println("关闭 wechat consumer 完成!")
 		return nil