-
- private Gauge getQueueSizeGuage(final MeteredMessageQueue monitoredQueue ){
- return new Gauge<Integer>() {
- @Override
- public Integer getValue() {
- return monitoredQueue.size();
- }
- };
- }
-
- private void registerQueueSizeMetric(String metricName, Gauge metric){
- try {
- registry.register(metricName,metric);
- } catch (IllegalArgumentException e) {
- LOG.warn("Unable to register queue size in metrics registry. Failed with exception {}. ", e);
- }
- }