diff --git a/hystrix-contrib/hystrix-codahale-metrics-publisher/src/main/java/com/netflix/hystrix/contrib/codahalemetricspublisher/HystrixCodaHaleMetricsPublisherCommand.java b/hystrix-contrib/hystrix-codahale-metrics-publisher/src/main/java/com/netflix/hystrix/contrib/codahalemetricspublisher/HystrixCodaHaleMetricsPublisherCommand.java index 214d7dc85..09f4f0e2a 100644 --- a/hystrix-contrib/hystrix-codahale-metrics-publisher/src/main/java/com/netflix/hystrix/contrib/codahalemetricspublisher/HystrixCodaHaleMetricsPublisherCommand.java +++ b/hystrix-contrib/hystrix-codahale-metrics-publisher/src/main/java/com/netflix/hystrix/contrib/codahalemetricspublisher/HystrixCodaHaleMetricsPublisherCommand.java @@ -272,6 +272,13 @@ public HystrixRollingNumberEvent call() { return HystrixRollingNumberEvent.TIMEOUT; } }); + // the rolling number of MaxConcurrentExecutionCount. Can be used to determine saturation + safelyCreateRollingCountForEvent("rollingMaxConcurentExecutionCount", new Func0() { + @Override + public HystrixRollingNumberEvent call() { + return HystrixRollingNumberEvent.COMMAND_MAX_ACTIVE; + } + }); // the number of executionSemaphorePermits in use right now metricRegistry.register(createMetricName("executionSemaphorePermitsInUse"), new Gauge() {