Convert ClientException in get operation

acogoluegnes · acogoluegnes · commit 8ea26772ac45 · 2024-12-17T18:37:09.000+01:00
diff --git a/src/main/java/com/rabbitmq/client/amqp/impl/AmqpManagement.java b/src/main/java/com/rabbitmq/client/amqp/impl/AmqpManagement.java
@@ -122,7 +122,9 @@ public QueueInfo queueInfo(String name) {
       Map<String, Object> queueInfo = get(queueLocation(name)).responseBodyAsMap();
       return new DefaultQueueInfo(queueInfo);
     } catch (ClientException e) {
-      throw new AmqpException("Error while fetching queue '%s' information", name);
+      String message = String.format("Error while fetching information for queue '%s'", name);
+      LOGGER.debug(message, e);
+      throw ExceptionUtils.convert(e, message);
     }
   }
 

Original file line number	Diff line number	Diff line change
`@@ -122,7 +122,9 @@ public QueueInfo queueInfo(String name) {`
`122`	`122`	`Map<String, Object> queueInfo = get(queueLocation(name)).responseBodyAsMap();`
`123`	`123`	`return new DefaultQueueInfo(queueInfo);`
`124`	`124`	`} catch (ClientException e) {`
`125`		`- throw new AmqpException("Error while fetching queue '%s' information", name);`
	`125`	`+ String message = String.format("Error while fetching information for queue '%s'", name);`
	`126`	`+ LOGGER.debug(message, e);`
	`127`	`+ throw ExceptionUtils.convert(e, message);`
`126`	`128`	`}`
`127`	`129`	`}`
`128`	`130`