From c9de1970736c4191974f0f176398807045d1d43e Mon Sep 17 00:00:00 2001 From: Mikko Kortelainen Date: Mon, 6 May 2024 15:19:08 +0300 Subject: [PATCH] add simple logging about HttpResponseStatus.TOO_MANY_REQUESTS and HttpResponseStatus.INTERNAL_SERVER_ERROR (#58) --- src/main/java/com/teragrep/lsh_01/MessageProcessor.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/teragrep/lsh_01/MessageProcessor.java b/src/main/java/com/teragrep/lsh_01/MessageProcessor.java index fc379cba..9e600a0b 100644 --- a/src/main/java/com/teragrep/lsh_01/MessageProcessor.java +++ b/src/main/java/com/teragrep/lsh_01/MessageProcessor.java @@ -72,6 +72,7 @@ public class MessageProcessor implements RejectableRunnable { public void onRejection() { try { final FullHttpResponse response = generateFailedResponse(HttpResponseStatus.TOO_MANY_REQUESTS); + LOGGER.warn("Too many requests, returning code <{}>", response.status().code()); ctx.writeAndFlush(response); } finally { @@ -140,7 +141,9 @@ private FullHttpResponse processMessage(Subject subject) { return generateResponse(messageHandler.responseHeaders()); } else { - return generateFailedResponse(HttpResponseStatus.INTERNAL_SERVER_ERROR); + FullHttpResponse response = generateFailedResponse(HttpResponseStatus.INTERNAL_SERVER_ERROR); + LOGGER.warn("Processing failed, returning code <{}>", response.status().code()); + return response; } }