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