#354 | track publishing failures

Author: slayful

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

@@ -36,6 +36,8 @@ public interface MetricsCollector {
 
     void basicPublish(Channel channel);
 
+    void basicPublishFailure(Channel channel);
+
     void consumedMessage(Channel channel, long deliveryTag, boolean autoAck);
 
     void consumedMessage(Channel channel, long deliveryTag, String consumerTag);
@@ -49,4 +51,5 @@ public interface MetricsCollector {
     void basicConsume(Channel channel, String consumerTag, boolean autoAck);
 
     void basicCancel(Channel channel, String consumerTag);
+
 }

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

@@ -684,22 +684,25 @@ public void basicPublish(String exchange, String routingKey,
             unconfirmedSet.add(getNextPublishSeqNo());
             nextPublishSeqNo++;
         }
-        BasicProperties useProps = props;
         if (props == null) {
-            useProps = MessageProperties.MINIMAL_BASIC;
+            props = MessageProperties.MINIMAL_BASIC;
+        }
+        AMQCommand command = new AMQCommand(
+            new Basic.Publish.Builder()
+                .exchange(exchange)
+                .routingKey(routingKey)
+                .mandatory(mandatory)
+                .immediate(immediate)
+                .build(), props, body);
+        try {
+            transmit(command);
+        } catch (IOException e) {
+            metricsCollector.basicPublishFailure(this);
+            throw e;
         }
-        transmit(new AMQCommand(new Basic.Publish.Builder()
-                                        .exchange(exchange)
-                                        .routingKey(routingKey)
-                                        .mandatory(mandatory)
-                                        .immediate(immediate)
-                                        .build(),
-                                       useProps, body));
         metricsCollector.basicPublish(this);
     }
 
-
-
     /** Public API - {@inheritDoc} */
     @Override
     public Exchange.DeclareOk exchangeDeclare(String exchange, String type,