#354 | micrometer metrics implementation

Author: slayful

src/main/java/com/rabbitmq/client/impl/MicrometerMetricsCollector.java

@@ -27,12 +27,7 @@
 import java.util.concurrent.atomic.AtomicLong;
 import java.util.function.Function;
 
-import static com.rabbitmq.client.impl.MicrometerMetricsCollector.Metrics.ACKNOWLEDGED_MESSAGES;
-import static com.rabbitmq.client.impl.MicrometerMetricsCollector.Metrics.CHANNELS;
-import static com.rabbitmq.client.impl.MicrometerMetricsCollector.Metrics.CONNECTIONS;
-import static com.rabbitmq.client.impl.MicrometerMetricsCollector.Metrics.CONSUMED_MESSAGES;
-import static com.rabbitmq.client.impl.MicrometerMetricsCollector.Metrics.PUBLISHED_MESSAGES;
-import static com.rabbitmq.client.impl.MicrometerMetricsCollector.Metrics.REJECTED_MESSAGES;
+import static com.rabbitmq.client.impl.MicrometerMetricsCollector.Metrics.*;
 
 /**
  * Micrometer implementation of {@link MetricsCollector}.
@@ -54,6 +49,8 @@ public class MicrometerMetricsCollector extends AbstractMetricsCollector {
 
     private final Counter publishedMessages;
 
+    private final Counter failedToPublishMessages;
+
     private final Counter consumedMessages;
 
     private final Counter acknowledgedMessages;
@@ -83,6 +80,7 @@ public MicrometerMetricsCollector(Function<Metrics, Object> metricsCreator) {
         this.consumedMessages = (Counter) metricsCreator.apply(CONSUMED_MESSAGES);
         this.acknowledgedMessages = (Counter) metricsCreator.apply(ACKNOWLEDGED_MESSAGES);
         this.rejectedMessages = (Counter) metricsCreator.apply(REJECTED_MESSAGES);
+        this.failedToPublishMessages = (Counter) metricsCreator.apply(FAILED_TO_PUBLISH_MESSAGES);
     }
 
     @Override
@@ -110,6 +108,11 @@ protected void markPublishedMessage() {
         publishedMessages.increment();
     }
 
+    @Override
+    protected void markMessagePublishFailed() {
+        failedToPublishMessages.increment();
+    }
+
     @Override
     protected void markConsumedMessage() {
         consumedMessages.increment();
@@ -137,6 +140,10 @@ public Counter getPublishedMessages() {
         return publishedMessages;
     }
 
+    public Counter getFailedToPublishMessages() {
+        return failedToPublishMessages;
+    }
+
     public Counter getConsumedMessages() {
         return consumedMessages;
     }
@@ -185,14 +192,19 @@ Object create(MeterRegistry registry, String prefix, Iterable<Tag> tags) {
             Object create(MeterRegistry registry, String prefix, Iterable<Tag> tags) {
                 return registry.counter(prefix + ".rejected", tags);
             }
+        },
+        FAILED_TO_PUBLISH_MESSAGES {
+            @Override
+            Object create(MeterRegistry registry, String prefix, Iterable<Tag> tags) {
+                return registry.counter(prefix + ".failed_to_publish", tags);
+            }
         };
 
         /**
          *
          * @param registry
          * @param prefix
          * @deprecated will be removed in 6.0.0
-         * @return
          */
         @Deprecated
         Object create(MeterRegistry registry, String prefix) {