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