日志打印

This commit is contained in:
三丙
2024-10-30 10:52:39 +08:00
parent 919f51ef49
commit d3b6623499

View File

@@ -26,7 +26,7 @@ public final class DefaultInMemoryStorage implements InMemoryStorage {
public void printStats() {
storage.forEach((topic, queue) -> {
if (!queue.isEmpty()) {
log.info("[{}] Queue Size [{}]", topic, queue.size());
log.info("[{}] Memory Queue Size [{}]", topic, queue.size());
}
});
}