From 580af7f57724a14d5b0d2a69db97aa202b40b986 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E5=AD=90=E9=93=AD?= Date: Tue, 18 Mar 2025 09:37:05 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B4=BB=E5=8A=A8=E6=89=B9=E6=AC=A1=E6=9F=A5?= =?UTF-8?q?=E8=AF=A2=E7=A1=AE=E8=AE=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/server/wechat_notify_consumer.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/internal/server/wechat_notify_consumer.go b/internal/server/wechat_notify_consumer.go index 8ceb518..5001b71 100644 --- a/internal/server/wechat_notify_consumer.go +++ b/internal/server/wechat_notify_consumer.go @@ -35,11 +35,10 @@ func NewWechatNotifyConsumer( func (w *WechatNotifyConsumer) Start(ctx context.Context) error { if !w.conf.WechatNotifyMQ.IsOpenConsumer { + log.Warnf("wechat notify consumer is not open") return nil } - fmt.Printf("wechat notify consumer 启动中...") - // 设置HTTP协议客户端接入点，进入消息队列RocketMQ版控制台实例详情页面的接入点区域查看。 endpoint := w.conf.WechatNotifyMQ.EndPoint // 请确保环境变量ALIBABA_CLOUD_ACCESS_KEY_ID、ALIBABA_CLOUD_ACCESS_KEY_SECRET已设置。