From 86397d169d366a3e2c4ddd088b50fb5011ae04f9 Mon Sep 17 00:00:00 2001 From: super_liu <396572590@qq.com> Date: Thu, 23 Sep 2021 17:59:52 +0800 Subject: [PATCH] feat: There is no way the --- .../ydw/bat/wkflow/business_mq/service/SendDoneMQService.java | 1 + .../com/ydw/bat/wkflow/business_mq/service/SendMQService.java | 1 + 2 files changed, 2 insertions(+) diff --git a/src/main/java/com/ydw/bat/wkflow/business_mq/service/SendDoneMQService.java b/src/main/java/com/ydw/bat/wkflow/business_mq/service/SendDoneMQService.java index 7abeec3d..aa16152b 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_mq/service/SendDoneMQService.java +++ b/src/main/java/com/ydw/bat/wkflow/business_mq/service/SendDoneMQService.java @@ -56,6 +56,7 @@ public class SendDoneMQService { public void createMQDone(NotifyTodoSendContext object, Message message, Channel channel) throws Exception{ try{ try{ + Thread.sleep(5000); insertOrUpdateInfo(object); }catch(InterruptedException e){ logger.error(e.toString()); diff --git a/src/main/java/com/ydw/bat/wkflow/business_mq/service/SendMQService.java b/src/main/java/com/ydw/bat/wkflow/business_mq/service/SendMQService.java index 7ce1db14..a949bb18 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_mq/service/SendMQService.java +++ b/src/main/java/com/ydw/bat/wkflow/business_mq/service/SendMQService.java @@ -56,6 +56,7 @@ public class SendMQService { public void createMQ(BusProcessNew object, Message message, Channel channel) throws Exception{ try{ try{ + Thread.sleep(5000); insertOrUpdateInfo(object); }catch(InterruptedException e){ logger.error(e.toString());