123

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/mqhandler/VehicleReceiveMQHandler.java

@@ -39,6 +39,11 @@ public class VehicleReceiveMQHandler {
     @RabbitListener(queues = VEHICLE_RECEVIE_REFUND_QUEUE)
     public void integralHandler(Message message, @Headers Map<String, Object> headers, Channel channel) {
         log.info("接单退款信息 messageJson："+ JSONUtil.parse(message));
+        try {
+            Thread.sleep(2000L);
+        }catch (Exception e) {
+            log.error(e.getMessage(), e);
+        }
         ExecutorService executorService = Executors.newCachedThreadPool();
         executorService.execute(new Runnable() {
             @Override