From 856d0058cbdf12f744a63b6ebb8857c034a07dbc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E5=AD=90=E9=93=AD?= Date: Thu, 20 Mar 2025 19:19:04 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9F=A5=E8=AF=A2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/server/wechat_notify_consumer.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/server/wechat_notify_consumer.go b/internal/server/wechat_notify_consumer.go index fc8ce97..309e439 100644 --- a/internal/server/wechat_notify_consumer.go +++ b/internal/server/wechat_notify_consumer.go @@ -101,7 +101,7 @@ func (w *WechatNotifyConsumer) consumeMessages(mqConsumer mq_http_sdk.MQConsumer { // Topic中没有消息可消费。 if strings.Contains(err.(errors.ErrCode).Error(), "MessageNotExist") { - fmt.Println("\nNo new message, continue!") + //fmt.Println("\nNo new message, continue!") } else { log.Errorf("ConsumeMessage Failed, err:%s\n", err) time.Sleep(time.Duration(3) * time.Second) @@ -120,7 +120,7 @@ func (w *WechatNotifyConsumer) consumeMessages(mqConsumer mq_http_sdk.MQConsumer // 长轮询表示如果Topic没有消息，则客户端请求会在服务端挂起3s，3s内如果有消息可以消费则立即返回响应。 mqConsumer.ConsumeMessage(respChan, errChan, 5, // 一次最多消费3条（最多可设置为16条）。 - 15, // 长轮询时间3s（最多可设置为30s）。 + 20, // 长轮询时间3s（最多可设置为30s）。 ) <-endChan }