#354 | standard metrics implementation

Author: slayful

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

@@ -41,13 +41,15 @@ public class StandardMetricsCollector extends AbstractMetricsCollector {
     private final Meter consumedMessages;
     private final Meter acknowledgedMessages;
     private final Meter rejectedMessages;
+    private final Meter failedToPublishMessages;
 
 
     public StandardMetricsCollector(MetricRegistry registry, String metricsPrefix) {
         this.registry = registry;
         this.connections = registry.counter(metricsPrefix+".connections");
         this.channels = registry.counter(metricsPrefix+".channels");
         this.publishedMessages = registry.meter(metricsPrefix+".published");
+        this.failedToPublishMessages = registry.meter(metricsPrefix+".failed_to_publish");
         this.consumedMessages = registry.meter(metricsPrefix+".consumed");
         this.acknowledgedMessages = registry.meter(metricsPrefix+".acknowledged");
         this.rejectedMessages = registry.meter(metricsPrefix+".rejected");
@@ -86,6 +88,11 @@ protected void markPublishedMessage() {
         publishedMessages.mark();
     }
 
+    @Override
+    protected void markMessagePublishFailed() {
+        failedToPublishMessages.mark();
+    }
+
     @Override
     protected void markConsumedMessage() {
         consumedMessages.mark();
@@ -130,4 +137,8 @@ public Meter getAcknowledgedMessages() {
     public Meter getRejectedMessages() {
         return rejectedMessages;
     }
+
+    public Meter getFailedToPublishMessages() {
+        return failedToPublishMessages;
+    }
 }