diff --git a/extensions/micrometer/runtime/src/main/java/io/quarkus/micrometer/runtime/binder/vertx/VertxPoolMetrics.java b/extensions/micrometer/runtime/src/main/java/io/quarkus/micrometer/runtime/binder/vertx/VertxPoolMetrics.java index 32c62b00691da..9a9da31c36258 100644 --- a/extensions/micrometer/runtime/src/main/java/io/quarkus/micrometer/runtime/binder/vertx/VertxPoolMetrics.java +++ b/extensions/micrometer/runtime/src/main/java/io/quarkus/micrometer/runtime/binder/vertx/VertxPoolMetrics.java @@ -25,6 +25,7 @@ public class VertxPoolMetrics implements PoolMetrics { private final LongAdder current = new LongAdder(); private final LongAdder queue = new LongAdder(); private final Counter completed; + private final Counter rejected; private final Timer queueDelay; VertxPoolMetrics(MeterRegistry registry, String poolType, String poolName, int maxPoolSize) { @@ -89,6 +90,11 @@ public Number get() { .tags(tags) .register(registry); + rejected = Counter.builder(name("rejected")) + .description("Number of times submissions to the pool have been rejected") + .tags(tags) + .register(registry); + } private String name(String suffix) { @@ -104,6 +110,7 @@ public EventTiming submitted() { @Override public void rejected(EventTiming submitted) { queue.decrement(); + rejected.increment(); submitted.end(); }