Skip to content

Commit f113046

Browse files
committed
enable TcpClient metrics
1 parent 9d9e763 commit f113046

File tree

1 file changed

+5
-0
lines changed
  • r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/client

1 file changed

+5
-0
lines changed

r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/client/Client.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@
2929
import reactor.core.publisher.Flux;
3030
import reactor.core.publisher.Mono;
3131
import reactor.core.publisher.SynchronousSink;
32+
import reactor.netty.internal.util.Metrics;
3233
import reactor.netty.resources.LoopResources;
3334
import reactor.netty.tcp.TcpClient;
3435

@@ -155,6 +156,10 @@ static Mono<Client> connect(MySqlSslConfiguration ssl, SocketAddress address, bo
155156
tcpClient = tcpClient.resolver(resolver);
156157
}
157158

159+
if (Metrics.isMicrometerAvailable()) {
160+
tcpClient.metrics(true);
161+
}
162+
158163
return tcpClient.remoteAddress(() -> address).connect()
159164
.map(conn -> new ReactorNettyClient(conn, ssl, context));
160165
}

0 commit comments

Comments
 (0)