QPID-2002 : Add Queue Logging Tests.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@801564 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 6 insertions, 3 deletions

diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java
index 47a0a1d830..763a0506e3 100644
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java
@@ -160,10 +160,9 @@ public class SimpleAMQQueue implements AMQQueue, Subscription.StateListener
         // Extract the number of priorities for this Queue.
         // Leave it as 0 if we are a SimpleQueueEntryList
         int priorities = 0;
-        if (entryListFactory instanceof PriorityQueueList)
+        if (entryListFactory instanceof PriorityQueueList.Factory)
         {
-            PriorityQueueList priorityFactory = (PriorityQueueList) entryListFactory;
-            priorities = priorityFactory.getPriorities();
+            priorities = ((PriorityQueueList)_entries).getPriorities();
         }
 
         // Log the creation of this Queue.
@@ -1165,6 +1164,10 @@ public class SimpleAMQQueue implements AMQQueue, Subscription.StateListener
 
             _deleteTaskList.clear();
             stop();
+            
+            //Log Queue Deletion
+            CurrentActor.get().message(_logSubject, QueueMessages.QUE_1002());
+
         }
         return getMessageCount();