微信回调消费接收消息成功
This commit is contained in:
parent
28968842ed
commit
e3085019f4
|
|
@ -150,11 +150,9 @@ func (w *WechatNotifyConsumer) processMessage(msg mq_http_sdk.ConsumeMessageEntr
|
||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
|
|
||||||
log.Warnf("微信回调消费接收消息成功 messageId:%s, messageTag:%s, message: %s", msg.MessageId, msg.MessageTag, msg.MessageBody)
|
|
||||||
|
|
||||||
ctx := context.Background()
|
ctx := context.Background()
|
||||||
if err := w.voucherService.WechatUseNotifyConsumer(ctx, msg.MessageTag, msg.MessageBody); err != nil {
|
if err := w.voucherService.WechatUseNotifyConsumer(ctx, msg.MessageTag, msg.MessageBody); err != nil {
|
||||||
log.Errorf("微信回调消费处理失败:%+v", err)
|
log.Errorf("微信回调消费接收消息成功,处理失败 messageId:%s, messageTag:%s, message: %s, err:%+v", msg.MessageId, msg.MessageTag, msg.MessageBody, err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue