diff --git a/pom.xml b/pom.xml index 91cdd53c5..148a80884 100644 --- a/pom.xml +++ b/pom.xml @@ -14,7 +14,7 @@ Provides a modern and scalable web server as SIRIUS module - 12.0-rc16 + 12.0-rc19 diff --git a/src/main/java/sirius/web/crunchlog/CrunchlogKernel.java b/src/main/java/sirius/web/crunchlog/CrunchlogKernel.java index 29691b7c6..027c22985 100644 --- a/src/main/java/sirius/web/crunchlog/CrunchlogKernel.java +++ b/src/main/java/sirius/web/crunchlog/CrunchlogKernel.java @@ -109,25 +109,27 @@ protected double maxCallFrequency() { } @Override - protected void doWork() throws Exception { + protected String doWork() throws Exception { if (buffer.isEmpty()) { - return; + return null; } if (!ensureWriterIsReady()) { buffer.clear(); - return; + return null; } try { + int numWritten = 0; while (TaskContext.get().isActive()) { Context line = buffer.poll(); if (line == null) { - return; + return "Crunchlogs written: " + numWritten; } String lineAsString = JSON.toJSONString(line); currentWriter.write(lineAsString); currentWriter.write("\n"); + numWritten++; } currentWriter.flush(); @@ -140,6 +142,7 @@ protected void doWork() throws Exception { Exceptions.handle(Crunchlog.LOG, e); buffer.clear(); } + return null; } /**