diff --git a/spring-rabbitmq-client/src/main/java/org/springframework/amqp/rabbitmq/client/RabbitAmqpAdmin.java b/spring-rabbitmq-client/src/main/java/org/springframework/amqp/rabbitmq/client/RabbitAmqpAdmin.java index 0f932112..21c934b7 100644 --- a/spring-rabbitmq-client/src/main/java/org/springframework/amqp/rabbitmq/client/RabbitAmqpAdmin.java +++ b/spring-rabbitmq-client/src/main/java/org/springframework/amqp/rabbitmq/client/RabbitAmqpAdmin.java @@ -402,9 +402,8 @@ public class RabbitAmqpAdmin @ManagedOperation(description = "Purge a queue and return the number of messages purged") public int purgeQueue(String queueName) { try (Management management = getManagement()) { - management.queuePurge(queueName); + return (int) management.queuePurge(queueName).messageCount(); } - return 0; } @Override