修改文件存储路径

23f48f28 · 赵啸非 · ab03413e · 23f48f28
Commit 23f48f28 authored Aug 26, 2022 by 赵啸非
Show whitespace changes
Inline Side-by-side

Showing with 6 additions and 2 deletions

common-lib/src/main/java/com/mortals/xhx/queue/rabbitmq/TbRabbitMqConsumerTemplate.java ...ortals/xhx/queue/rabbitmq/TbRabbitMqConsumerTemplate.java +6 -2

No files found.
--- a/common-lib/src/main/java/com/mortals/xhx/queue/rabbitmq/TbRabbitMqConsumerTemplate.java
+++ b/common-lib/src/main/java/com/mortals/xhx/queue/rabbitmq/TbRabbitMqConsumerTemplate.java
@@ -55,9 +55,13 @@ public class TbRabbitMqConsumerTemplate<T extends TbQueueMsg> extends AbstractTb
    }

    @Override
-    protected List<GetResponse> doPoll(long durationInMillis) throws InterruptedException {
+    protected List<GetResponse> doPoll(long durationInMillis)  {

+        try {
            Thread.sleep(500);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
        List<GetResponse> result = queues.stream()
                .map(queue -> {
                    try {