|
@@ -87,6 +87,12 @@ public class MessageConsumer {
|
|
|
batchCodes.remove(batchCode);
|
|
batchCodes.remove(batchCode);
|
|
|
return;
|
|
return;
|
|
|
}
|
|
}
|
|
|
|
|
+ try {
|
|
|
|
|
+ logger.info("sleep 1s...");
|
|
|
|
|
+ Thread.sleep(1000);
|
|
|
|
|
+ } catch (InterruptedException e) {
|
|
|
|
|
+ logger.error("sleep error", e);
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|