Minor

krystian-panek-vmltech · krystian-panek-vmltech · commit 23d1125b4dc1 · 2025-08-14T14:18:24.000+02:00
diff --git a/core/src/main/java/dev/vml/es/acm/core/code/ExecutionQueue.java b/core/src/main/java/dev/vml/es/acm/core/code/ExecutionQueue.java
@@ -129,7 +129,7 @@ public TopicStatistics getStatistics() {
         return StreamUtils.asStream(jobManager.getTopicStatistics().iterator())
                 .filter(ts -> TOPIC.equals(ts.getTopic()))
                 .findFirst()
-                .orElseThrow(() -> new AcmException(String.format("Cannot find topic statistics for topic '%s'!", TOPIC)));
+                .orElseThrow(() -> new AcmException(String.format("Cannot find statistics for topic '%s'!", TOPIC)));
     }
 
     public long getMaxSize() {

Original file line number	Diff line number	Diff line change
`@@ -129,7 +129,7 @@ public TopicStatistics getStatistics() {`
`129`	`129`	`return StreamUtils.asStream(jobManager.getTopicStatistics().iterator())`
`130`	`130`	`.filter(ts -> TOPIC.equals(ts.getTopic()))`
`131`	`131`	`.findFirst()`
`132`		`- .orElseThrow(() -> new AcmException(String.format("Cannot find topic statistics for topic '%s'!", TOPIC)));`
	`132`	`+ .orElseThrow(() -> new AcmException(String.format("Cannot find statistics for topic '%s'!", TOPIC)));`
`133`	`133`	`}`
`134`	`134`
`135`	`135`	`public long getMaxSize() {`