|
@@ -83,6 +83,7 @@ public class MessageConsumer {
|
|
|
subscribe();
|
|
subscribe();
|
|
|
while (true) {
|
|
while (true) {
|
|
|
if (batchCodes.contains(batchCode)) {
|
|
if (batchCodes.contains(batchCode)) {
|
|
|
|
|
+ logger.info("waited batchCode: " + batchCode);
|
|
|
batchCodes.remove(batchCode);
|
|
batchCodes.remove(batchCode);
|
|
|
return;
|
|
return;
|
|
|
}
|
|
}
|