Skip to content

Commit 66c5f59

Browse files
committed
Remove lambda from VertxHttpClientMetrics
1 parent 6f9a47c commit 66c5f59

File tree

1 file changed

+11
-7
lines changed

1 file changed

+11
-7
lines changed

extensions/micrometer/runtime/src/main/java/io/quarkus/micrometer/runtime/binder/vertx/VertxHttpClientMetrics.java

Lines changed: 11 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55
import java.util.concurrent.ConcurrentHashMap;
66
import java.util.concurrent.TimeUnit;
77
import java.util.concurrent.atomic.LongAdder;
8+
import java.util.function.Function;
89
import java.util.function.Supplier;
910
import java.util.regex.Pattern;
1011

@@ -143,13 +144,16 @@ public void responseEnd(RequestTracker tracker, long bytesRead) {
143144
@Override
144145
public String connected(WebSocket webSocket) {
145146
String remote = webSocket.remoteAddress().toString();
146-
webSockets.computeIfAbsent(remote, k -> {
147-
LongAdder count = new LongAdder();
148-
Gauge.builder(config.getHttpClientWebSocketConnectionsName(), count::longValue)
149-
.description("The number of active web socket connections")
150-
.tags(tags.and("address", remote))
151-
.register(registry);
152-
return count;
147+
webSockets.computeIfAbsent(remote, new Function<>() {
148+
@Override
149+
public LongAdder apply(String s) {
150+
LongAdder count = new LongAdder();
151+
Gauge.builder(config.getHttpClientWebSocketConnectionsName(), count::longValue)
152+
.description("The number of active web socket connections")
153+
.tags(tags.and("address", remote))
154+
.register(registry);
155+
return count;
156+
}
153157
}).increment();
154158
return remote;
155159
}

0 commit comments

Comments
 (0)