#354 | cause is passed to the metrics collector

Author: slayful

src/main/java/com/rabbitmq/client/MetricsCollector.java

@@ -36,7 +36,7 @@ public interface MetricsCollector {
 
     void basicPublish(Channel channel);
 
-    void basicPublishFailure(Channel channel);
+    void basicPublishFailure(Channel channel, Throwable cause);
 
     void consumedMessage(Channel channel, long deliveryTag, boolean autoAck);
 

src/main/java/com/rabbitmq/client/NoOpMetricsCollector.java

@@ -71,7 +71,7 @@ public void basicPublish(Channel channel) {
     }
 
     @Override
-    public void basicPublishFailure(Channel channel) {
+    public void basicPublishFailure(Channel channel, Throwable cause) {
 
     }
 

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

@@ -103,7 +103,7 @@ public void basicPublish(Channel channel) {
     }
 
     @Override
-    public void basicPublishFailure(Channel channel) {
+    public void basicPublishFailure(Channel channel, Throwable cause) {
         try {
             markMessagePublishFailed();
         } catch(Exception e) {

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

@@ -697,7 +697,7 @@ public void basicPublish(String exchange, String routingKey,
         try {
             transmit(command);
         } catch (IOException e) {
-            metricsCollector.basicPublishFailure(this);
+            metricsCollector.basicPublishFailure(this, e);
             throw e;
         }
         metricsCollector.basicPublish(this);