修改文件存储路径

common-lib/src/main/java/com/mortals/xhx/queue/kafka/AbstractTbQueueConsumerTemplate.java

@@ -148,7 +148,7 @@ public abstract class AbstractTbQueueConsumerTemplate<R, T extends TbQueueMsg> i
         }
     }
 
-    abstract protected List<R> doPoll(long durationInMillis);
+    abstract protected List<R> doPoll(long durationInMillis) throws InterruptedException;
 
     abstract protected T decode(R record);
 

common-lib/src/main/java/com/mortals/xhx/queue/rabbitmq/TbRabbitMqConsumerTemplate.java

@@ -55,7 +55,9 @@ public class TbRabbitMqConsumerTemplate<T extends TbQueueMsg> extends AbstractTb
     }
 
     @Override
-    protected List<GetResponse> doPoll(long durationInMillis) {
+    protected List<GetResponse> doPoll(long durationInMillis) throws InterruptedException {
+
+        Thread.sleep(500);
         List<GetResponse> result = queues.stream()
                 .map(queue -> {
                     try {

device-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/DeviceMsgComsumerStartedService.java

@@ -128,7 +128,7 @@ public class DeviceMsgComsumerStartedService implements IApplicationStartedServi
                         }
                     }
                 }
-                mainConsumer.commit();
+                //mainConsumer.commit();
             });
         }
     }