Return error response when request fails

1 files changed, 4 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 93700aa1a46..dbc6ed49a04 100644
--- a/logserver/src/main/java/ai/vespa/logserver/protocol/ArchiveLogMessagesMethod.java
+++ b/logserver/src/main/java/ai/vespa/logserver/protocol/ArchiveLogMessagesMethod.java
@@ -81,7 +81,10 @@ class ArchiveLogMessagesMethod {
                 rpcRequest.returnValues().add(new DataValue(responsePayload));
                 rpcRequest.returnRequest();
             } catch (Exception e) {
-                log.log(Level.WARNING, e, () -> "Failed to handle log request: " + e.getMessage());
+                String errorMessage = "Failed to handle log request: " + e.getMessage();
+                log.log(Level.WARNING, e, () -> errorMessage);
+                rpcRequest.setError(2, errorMessage);
+                rpcRequest.returnRequest();
             }
         }
     }