From a1860788d38a6caf30702531ddb596c23df83cb3 Mon Sep 17 00:00:00 2001 From: Nikita Nefedov Date: Mon, 23 Jan 2023 15:18:27 +0100 Subject: [PATCH] Report publish failures for the closed channel as well --- src/main/java/com/rabbitmq/client/impl/ChannelN.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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