Skip to content

D
device-new-platform
Commit 9e31a0b6 authored by 赵啸非's avatar 赵啸非
Browse files
Options

rrrrrrrrrrrrrrrrrrrrrrrr

parent f9184667
Show whitespace changes
Inline Side-by-side
Showing with 5 additions and 0 deletions
common-lib/src/main/java/com/mortals/xhx/queue/rabbitmq/TbRabbitMqConsumerTemplate.java
View file @ 9e31a0b6
...@@ -57,6 +57,11 @@ public class TbRabbitMqConsumerTemplate<T extends TbQueueMsg> extends AbstractTb ...@@ -57,6 +57,11 @@ public class TbRabbitMqConsumerTemplate<T extends TbQueueMsg> extends AbstractTb
@Override @Override
protected List<GetResponse> doPoll(long durationInMillis) { protected List<GetResponse> doPoll(long durationInMillis) {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
List<GetResponse> result = queues.stream() List<GetResponse> result = queues.stream()
.map(queue -> { .map(queue -> {
try { try {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment