Merge branch 'pro' into pre
This commit is contained in:
commit
729a23e410
|
|
@ -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
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue