diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/comfac/controller/FactoryCommonController.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/comfac/controller/FactoryCommonController.java index 11135b05b..677524c4b 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/comfac/controller/FactoryCommonController.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/comfac/controller/FactoryCommonController.java @@ -106,12 +106,12 @@ public class FactoryCommonController { map.put("flagType", "OrderStatusLog"); // 将消息携带绑定键值 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")) { - rabbitTemplate.convertAndSend(RabbitConstant.DEAL_WITH_EXCHANGE, RabbitConstant.DEAL_WITH_ROUTING, map, message -> { - message.getMessageProperties().setHeader("x-delay", 2000); - return message; - }); +// rabbitTemplate.convertAndSend(RabbitConstant.DEAL_WITH_EXCHANGE, RabbitConstant.DEAL_WITH_ROUTING, map, message -> { +// message.getMessageProperties().setHeader("x-delay", 2000); +// return message; +// }); // } // R r = factoryDataService.handleStatusData(orderStatusDTO);