From f113046c1e49c9351558c109b3bedf26a53fed1b Mon Sep 17 00:00:00 2001 From: rxdcxdrnine Date: Sat, 18 Jan 2025 17:47:01 +0900 Subject: [PATCH] enable TcpClient metrics --- .../src/main/java/io/asyncer/r2dbc/mysql/client/Client.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/client/Client.java b/r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/client/Client.java index 0beaf4c0d..00b84bf09 100644 --- a/r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/client/Client.java +++ b/r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/client/Client.java @@ -29,6 +29,7 @@ import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; import reactor.core.publisher.SynchronousSink; +import reactor.netty.internal.util.Metrics; import reactor.netty.resources.LoopResources; import reactor.netty.tcp.TcpClient; @@ -155,6 +156,10 @@ static Mono connect(MySqlSslConfiguration ssl, SocketAddress address, bo tcpClient = tcpClient.resolver(resolver); } + if (Metrics.isMicrometerAvailable()) { + tcpClient.metrics(true); + } + return tcpClient.remoteAddress(() -> address).connect() .map(conn -> new ReactorNettyClient(conn, ssl, context)); }