|
@@ -104,7 +104,7 @@ public class EtlMQConsumer {
|
|
log.error("consumeMessage error", e);
|
|
log.error("consumeMessage error", e);
|
|
}
|
|
}
|
|
if (messages == null || messages.isEmpty()) {
|
|
if (messages == null || messages.isEmpty()) {
|
|
- log.info("No new message, continue");
|
|
|
|
|
|
+// log.info("No new message, continue");
|
|
continue;
|
|
continue;
|
|
}
|
|
}
|
|
List<String> handles = new ArrayList<>();
|
|
List<String> handles = new ArrayList<>();
|