提交 6804d348 authored 作者: liuhaiquan's avatar liuhaiquan

修改队列消息延迟设置

上级 326ae873
...@@ -709,7 +709,7 @@ public class OrderCancelServiceImpl implements OrderCancelService { ...@@ -709,7 +709,7 @@ public class OrderCancelServiceImpl implements OrderCancelService {
mq.setUserNo(ownerUserNo); mq.setUserNo(ownerUserNo);
Message message = MessageBuilder.withBody(JSON.toJSONString(new MqWrapper<>(mq)).getBytes()).build(); Message message = MessageBuilder.withBody(JSON.toJSONString(new MqWrapper<>(mq)).getBytes()).build();
//设置延时5秒处理,防止事务未提交 //设置延时5秒处理,防止事务未提交
message.getMessageProperties().setExpiration("5000"); message.getMessageProperties().setHeader("x-delay", 5000);
rabbitTemplate.send(RabbitKeyConstants.FREEZE_TRIGGER_EXCHANGE, RabbitKeyConstants.FREEZE_TRIGGER_ROUTING_KEY,message); rabbitTemplate.send(RabbitKeyConstants.FREEZE_TRIGGER_EXCHANGE, RabbitKeyConstants.FREEZE_TRIGGER_ROUTING_KEY,message);
} }
}catch (Exception e){ }catch (Exception e){
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论