修改文件存储路径

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

@@ -71,6 +71,7 @@ public class DefaultTbCoreConsumerService extends AbstractConsumerService<TbQueu
                     }
 
                     mainConsumer.commit();
+                    Thread.sleep(200);
                 } catch (Exception e) {
                     if (!stopped) {
                         // log.warn("Failed to obtain messages from queue.", e);
@@ -111,6 +112,7 @@ public class DefaultTbCoreConsumerService extends AbstractConsumerService<TbQueu
                         }
 
                         consumer.commit();
+                        Thread.sleep(200);
                     } catch (Exception e) {
                         if (!stopped) {
                             try {

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

@@ -59,6 +59,7 @@ public class TbRabbitMqConsumerTemplate<T extends TbQueueMsg> extends AbstractTb
         List<GetResponse> result = queues.stream()
                 .map(queue -> {
                     try {
+
                         GetResponse getResponse = channel.basicGet(queue, true);
                         return getResponse;
                     } catch (IOException e) {