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());