Additional change to 12544db

reactor · Jun 24, 2022 · 770a7c3 · 770a7c3
1 parent 12544db
commit 770a7c3
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/...-netty-http/src/main/java/reactor/netty/http/client/AbstractHttpClientMetricsHandler.java b/...-netty-http/src/main/java/reactor/netty/http/client/AbstractHttpClientMetricsHandler.java
@@ -90,7 +90,15 @@ public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise)
 
 			if (msg instanceof LastHttpContent) {
 				SocketAddress address = ctx.channel().remoteAddress();
-				promise.addListener(future -> recordWrite(address));
+				promise.addListener(future -> {
+					try {
+						recordWrite(address);
+					}
+					catch (RuntimeException e) {
+						log.warn("Exception caught while recording metrics.", e);
+						// Allow request-response exchange to continue, unaffected by metrics problem
+					}
+				});
 			}
 		}
 		catch (RuntimeException e) {