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 }