检测服务关闭～

2025-05-26 14:17:42 +08:00 · 2025-05-26 14:17:42 +08:00 · 3e6e85fd82
parent 433982c75b
commit 3e6e85fd82
1 changed files with 5 additions and 0 deletions
--- a/internal/server/wechat_notify_consumer.go
+++ b/internal/server/wechat_notify_consumer.go
@ -160,6 +160,11 @@ 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
+	}
+
 	fmt.Println("关闭 wechat consumer 中...")

 	w.shutdownFlag.Store(true)