diff --git a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/memory/DefaultInMemoryStorage.java b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/memory/DefaultInMemoryStorage.java index e800140..155f512 100644 --- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/memory/DefaultInMemoryStorage.java +++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/memory/DefaultInMemoryStorage.java @@ -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()); } }); }