Commit ca407882 authored by libin's avatar libin

用户提现

parent fb60b84f
......@@ -95,7 +95,12 @@ public class WithDrawMqHandler implements InitializingBean {
Long count = valueOperations.increment(orderNo);
if (count <= MAX_RETRY) {
//重新把消息放回队列
basicNack(channel, message.getMessageProperties().getDeliveryTag(), false, true, pay_way);
// basicNack(channel, message.getMessageProperties().getDeliveryTag(), false, true, pay_way);
try {
channel.basicRecover();
}catch (IOException ex){
}
return;
}
redisTemplate.delete(orderNo);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment