diff --git a/src/main/java/com/vehicle/service/impl/VehicleServiceImpl.java b/src/main/java/com/vehicle/service/impl/VehicleServiceImpl.java index c3d7cca..0462f7f 100644 --- a/src/main/java/com/vehicle/service/impl/VehicleServiceImpl.java +++ b/src/main/java/com/vehicle/service/impl/VehicleServiceImpl.java @@ -43,10 +43,10 @@ public class VehicleServiceImpl extends ServiceImpl { - msg.getMessageProperties().setMessageId(UUID.randomUUID().toString().replaceAll("-", "")); - return msg; - }); +// rabbitTemplate.convertAndSend("sub_top", "topic_" + vehicleOnlineReq.getVin(), msg -> { +// msg.getMessageProperties().setMessageId(UUID.randomUUID().toString().replaceAll("-", "")); +// return msg; +// }); return "topic_" + vehicleOnlineReq.getVin(); }