#354 | abstract metrics implementation

Author: slayful

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

@@ -102,6 +102,15 @@ public void basicPublish(Channel channel) {
         }
     }
 
+    @Override
+    public void basicPublishFailure(Channel channel) {
+        try {
+            markMessagePublishFailed();
+        } catch(Exception e) {
+            LOGGER.info("Error while computing metrics in basicPublishFailure: " + e.getMessage());
+        }
+    }
+
     @Override
     public void basicConsume(Channel channel, String consumerTag, boolean autoAck) {
         try {
@@ -331,6 +340,11 @@ private ChannelState(Channel channel) {
      */
     protected abstract void markPublishedMessage();
 
+    /**
+     * Marks the event of a message publishing failure.
+     */
+    protected abstract void markMessagePublishFailed();
+
     /**
      * Marks the event of a consumed message.
      */