diff options
Diffstat (limited to 'qpid/java/broker')
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java | 9 |
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(); |