diff options
| -rw-r--r-- | logserver/src/main/java/ai/vespa/logserver/protocol/ArchiveLogMessagesMethod.java | 5 |
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(); } } } |