commit 9ded8dbcc69cd3ae07d095c05ad29ee6db3dfbd5
author rgodfrey <rgodfrey@apache.org> Mon May 27 11:26:45 2019 +0200
committer rgodfrey <rgodfrey@apache.org> Mon May 27 11:26:45 2019 +0200
tree 014c63d61113f1335cba038227cf15dda724c17b
parent 84700b9c0341c26393d9e826509613d7bf530c86

QPID-8318 : Queue.Purge does not return deleted count

broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java

diff --git a/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java b/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java
index d0f2f30..375732b 100644
--- a/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java
+++ b/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java
@@ -1748,20 +1748,13 @@
         while (queueListIterator.advance())
         {
             final QueueEntry node = queueListIterator.getNode();
-            boolean acquired = node.acquireOrSteal(new Runnable()
-                                                    {
-                                                        @Override
-                                                        public void run()
-                                                        {
-                                                            dequeueEntry(node);
-                                                        }
-                                                    });
+            boolean acquired = node.acquireOrSteal(() -> dequeueEntry(node));
 
             if (acquired)
             {
                 dequeueEntry(node, txn);
+                count++;
             }
-
         }
 
         txn.commit();