From 06f5dd2d5fe67759cada6988eddfb59da2eec052 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 14:06:04 +0800 Subject: [PATCH] =?UTF-8?q?=E5=9B=9E=E8=B0=83=E9=80=9A=E7=9F=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/server/wechat_notify_consumer.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/internal/server/wechat_notify_consumer.go b/internal/server/wechat_notify_consumer.go index 40ddc3b..b9d0bb0 100644 --- a/internal/server/wechat_notify_consumer.go +++ b/internal/server/wechat_notify_consumer.go @@ -80,10 +80,11 @@ func (w *WechatNotifyConsumer) consumeMessages(ctx context.Context, mqConsumer m var handles []string for _, v := range resp.Messages { handles = append(handles, v.ReceiptHandle) + log.Warnf("微信回调消费接收消息成功 messageTag:%s, message: %s", v.MessageTag, v.MessageBody) if err := w.voucherService.WechatUseNotifyConsumer(ctx, v.MessageTag, v.MessageBody); err != nil { - log.Errorf("微信回调消费处理失败err:%+v", err) + log.Errorf("微信回调消费处理失败:%+v", err) } } @@ -128,7 +129,7 @@ func (w *WechatNotifyConsumer) consumeMessages(ctx context.Context, mqConsumer m // 长轮询消费消息，网络超时时间默认为35s。 // 长轮询表示如果Topic没有消息，则客户端请求会在服务端挂起3s，3s内如果有消息可以消费则立即返回响应。 mqConsumer.ConsumeMessage(respChan, errChan, - 3, // 一次最多消费3条（最多可设置为16条）。 + 1, // 一次最多消费3条（最多可设置为16条）。 10, // 长轮询时间3s（最多可设置为30s）。 ) <-endChan