Support handling a list of log messages and flush after each time.

3 files changed, 5 insertions, 1 deletions

diff --git a/logserver/src/main/java/ai/vespa/logserver/protocol/ArchiveLogMessagesMethod.java b/logserver/src/main/java/ai/vespa/logserver/protocol/ArchiveLogMessagesMethod.java
index 9d234b73692..f210ce38457 100644
--- a/logserver/src/main/java/ai/vespa/logserver/protocol/ArchiveLogMessagesMethod.java
+++ b/logserver/src/main/java/ai/vespa/logserver/protocol/ArchiveLogMessagesMethod.java
@@ -76,6 +76,7 @@ public class ArchiveLogMessagesMethod {
                     return;
                 }
                 logDispatcher.handle(ProtobufSerialization.fromLogRequest(logRequestPayload));
+                logDispatcher.flush();
                 rpcRequest.returnValues().add(new Int8Value((byte)0));
                 byte[] responsePayload = ProtobufSerialization.toLogResponse();
                 rpcRequest.returnValues().add(new Int32Value(responsePayload.length));
diff --git a/logserver/src/main/java/com/yahoo/logserver/LogDispatcher.java b/logserver/src/main/java/com/yahoo/logserver/LogDispatcher.java
index 65fa83598b6..9b5816dc252 100644
--- a/logserver/src/main/java/com/yahoo/logserver/LogDispatcher.java
+++ b/logserver/src/main/java/com/yahoo/logserver/LogDispatcher.java
@@ -88,7 +88,9 @@ public class LogDispatcher implements LogHandler, SelectLoopHook {
     }
 
     public void handle(List<LogMessage> messages) {
-        throw new IllegalStateException("method not supported");
+        for (var message : messages) {
+            handle(message);
+        }
     }
 
     /**
diff --git a/logserver/src/test/java/ai/vespa/logserver/protocol/ArchiveLogMessagesMethodTest.java b/logserver/src/test/java/ai/vespa/logserver/protocol/ArchiveLogMessagesMethodTest.java
index a30df6bb050..847975bf2d9 100644
--- a/logserver/src/test/java/ai/vespa/logserver/protocol/ArchiveLogMessagesMethodTest.java
+++ b/logserver/src/test/java/ai/vespa/logserver/protocol/ArchiveLogMessagesMethodTest.java
@@ -47,6 +47,7 @@ public class ArchiveLogMessagesMethodTest {
             }
         }
         verify(logDispatcher).handle(new ArrayList<>(messages));
+        verify(logDispatcher).flush();
     }
 
     private static class TestClient implements AutoCloseable {