diff --git a/src/main/java/com/rabbitmq/client/impl/ChannelN.java b/src/main/java/com/rabbitmq/client/impl/ChannelN.java index 8dc19f4ad6..428224a4bc 100644 --- a/src/main/java/com/rabbitmq/client/impl/ChannelN.java +++ b/src/main/java/com/rabbitmq/client/impl/ChannelN.java @@ -710,7 +710,7 @@ public void basicPublish(String exchange, String routingKey, .build(), props, body); try { transmit(command); - } catch (IOException e) { + } catch (IOException | AlreadyClosedException e) { metricsCollector.basicPublishFailure(this, e); throw e; } @@ -1493,7 +1493,7 @@ public Consumer transformReply(AMQCommand replyCommand) { rpc(m, k); - + try { if(_rpcTimeout == NO_RPC_TIMEOUT) { k.getReply(); // discard result