From 0c010536156241c97d881d0def796a32be25abda Mon Sep 17 00:00:00 2001 From: ziming Date: Mon, 12 May 2025 09:50:31 +0800 Subject: [PATCH] =?UTF-8?q?=E5=87=8F=E5=B0=91=E4=B8=80=E6=AC=A1=E6=B6=88?= =?UTF-8?q?=E8=B4=B9=E6=9D=A1=E6=95=B0?= 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 309e439..d80ad2c 100644 --- a/internal/server/wechat_notify_consumer.go +++ b/internal/server/wechat_notify_consumer.go @@ -119,8 +119,8 @@ func (w *WechatNotifyConsumer) consumeMessages(mqConsumer mq_http_sdk.MQConsumer // 长轮询消费消息，网络超时时间默认为35s。 // 长轮询表示如果Topic没有消息，则客户端请求会在服务端挂起3s，3s内如果有消息可以消费则立即返回响应。 mqConsumer.ConsumeMessage(respChan, errChan, - 5, // 一次最多消费3条（最多可设置为16条）。 - 20, // 长轮询时间3s（最多可设置为30s）。 + 3, // 一次最多消费3条（最多可设置为16条）。 + 10, // 长轮询时间3s（最多可设置为30s）。 ) <-endChan }