Use lambda

Author: acogoluegnes

src/main/java/com/rabbitmq/stream/perf/DebugEndpointMonitoring.java

@@ -46,17 +46,14 @@ public void configure(MonitoringContext context) {
       PlainTextThreadDumpFormatter formatter = new PlainTextThreadDumpFormatter();
       context.addHttpEndpoint(
           "threaddump",
-          new HttpHandler() {
-            @Override
-            public void handle(HttpExchange exchange) throws IOException {
-              ThreadInfo[] threadInfos =
-                  ManagementFactory.getThreadMXBean().dumpAllThreads(true, true);
-              exchange.getResponseHeaders().set("Content-Type", "text/plain");
-              byte[] content = formatter.format(threadInfos).getBytes(StandardCharsets.UTF_8);
-              exchange.sendResponseHeaders(200, content.length);
-              try (OutputStream out = exchange.getResponseBody()) {
-                out.write(content);
-              }
+          exchange -> {
+            ThreadInfo[] threadInfos =
+                ManagementFactory.getThreadMXBean().dumpAllThreads(true, true);
+            exchange.getResponseHeaders().set("Content-Type", "text/plain");
+            byte[] content = formatter.format(threadInfos).getBytes(StandardCharsets.UTF_8);
+            exchange.sendResponseHeaders(200, content.length);
+            try (OutputStream out = exchange.getResponseBody()) {
+              out.write(content);
             }
           });
     }

src/main/java/com/rabbitmq/stream/perf/PrometheusEndpointMonitoring.java

@@ -39,15 +39,12 @@ public void configure(MonitoringContext context) {
       context.meterRegistry().add(registry);
       context.addHttpEndpoint(
           "metrics",
-          new HttpHandler() {
-            @Override
-            public void handle(HttpExchange exchange) throws IOException {
-              exchange.getResponseHeaders().set("Content-Type", "text/plain");
-              byte[] content = registry.scrape().getBytes(StandardCharsets.UTF_8);
-              exchange.sendResponseHeaders(200, content.length);
-              try (OutputStream out = exchange.getResponseBody()) {
-                out.write(content);
-              }
+          exchange -> {
+            exchange.getResponseHeaders().set("Content-Type", "text/plain");
+            byte[] content = registry.scrape().getBytes(StandardCharsets.UTF_8);
+            exchange.sendResponseHeaders(200, content.length);
+            try (OutputStream out = exchange.getResponseBody()) {
+              out.write(content);
             }
           });
     }