|
|
@ -106,12 +106,12 @@ public class FactoryCommonController { |
|
|
|
map.put("flagType", "OrderStatusLog"); |
|
|
|
map.put("flagType", "OrderStatusLog"); |
|
|
|
// 将消息携带绑定键值
|
|
|
|
// 将消息携带绑定键值
|
|
|
|
rabbitTemplate.convertAndSend(RabbitConstant.ORDER_STATUS_EXCHANGE, RabbitConstant.ORDER_STATUS_ROUTING, map); |
|
|
|
rabbitTemplate.convertAndSend(RabbitConstant.ORDER_STATUS_EXCHANGE, RabbitConstant.ORDER_STATUS_ROUTING, map); |
|
|
|
map.put("type", "DealWith"); |
|
|
|
// map.put("type", "DealWith");
|
|
|
|
// if (StringUtil.equals(sendDataProperties.getSend(), "old")) {
|
|
|
|
// if (StringUtil.equals(sendDataProperties.getSend(), "old")) {
|
|
|
|
rabbitTemplate.convertAndSend(RabbitConstant.DEAL_WITH_EXCHANGE, RabbitConstant.DEAL_WITH_ROUTING, map, message -> { |
|
|
|
// rabbitTemplate.convertAndSend(RabbitConstant.DEAL_WITH_EXCHANGE, RabbitConstant.DEAL_WITH_ROUTING, map, message -> {
|
|
|
|
message.getMessageProperties().setHeader("x-delay", 2000); |
|
|
|
// message.getMessageProperties().setHeader("x-delay", 2000);
|
|
|
|
return message; |
|
|
|
// return message;
|
|
|
|
}); |
|
|
|
// });
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
|
|
// R r = factoryDataService.handleStatusData(orderStatusDTO);
|
|
|
|
// R r = factoryDataService.handleStatusData(orderStatusDTO);
|
|
|
|