Fix checkstyle warnings

reactor · Jun 2, 2022 · 260cd97 · 260cd97
1 parent 7cba668
commit 260cd97
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 7 deletions.
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
@@ -91,7 +91,8 @@ public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise)
 			promise.addListener(future -> {
 				try {
 					recordWrite(address);
-				} catch (RuntimeException e) {
+				}
+				catch (RuntimeException e) {
 					log.warn("Exception caught while recording metrics.", e);
 					// Allow request-response exchange to continue, unaffected by metrics problem
 				}
@@ -116,7 +117,8 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) {
 				recordRead(ctx.channel().remoteAddress());
 				reset();
 			}
-		} catch (RuntimeException e) {
+		}
+		catch (RuntimeException e) {
 			log.warn("Exception caught while recording metrics.", e);
 			// Allow request-response exchange to continue, unaffected by metrics problem
 		}
@@ -127,7 +129,8 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) {
 	public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
 		try {
 			recordException(ctx);
-		} catch (RuntimeException e) {
+		}
+		catch (RuntimeException e) {
 			log.warn("Exception caught while recording metrics.", e);
 			// Allow request-response exchange to continue, unaffected by metrics problem
 		}

diff --git a/...-netty-http/src/main/java/reactor/netty/http/server/AbstractHttpServerMetricsHandler.java b/...-netty-http/src/main/java/reactor/netty/http/server/AbstractHttpServerMetricsHandler.java
@@ -31,7 +31,6 @@
 import reactor.util.annotation.Nullable;
 
 import java.time.Duration;
-import java.util.function.Consumer;
 import java.util.function.Function;
 
 /**
@@ -115,7 +114,8 @@ public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise)
 							recordInactiveConnection(ops);
 						}
 					}
-				} catch (RuntimeException e) {
+				}
+				catch (RuntimeException e) {
 					log.warn("Exception caught while recording metrics.", e);
 					// Allow request-response exchange to continue, unaffected by metrics problem
 				}
@@ -154,7 +154,8 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) {
 
 				dataReceived = 0;
 			}
-		} catch (RuntimeException e) {
+		}
+		catch (RuntimeException e) {
 			log.warn("Exception caught while recording metrics.", e);
 			// Allow request-response exchange to continue, unaffected by metrics problem
 		}
@@ -171,7 +172,8 @@ public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
 				// Always take the remote address from the operations in order to consider proxy information
 				recordException(ops, uriTagValue == null ? ops.path : uriTagValue.apply(ops.path));
 			}
-		} catch (RuntimeException e) {
+		}
+		catch (RuntimeException e) {
 			log.warn("Exception caught while recording metrics.", e);
 			// Allow request-response exchange to continue, unaffected by metrics problem
 		}