[AMQ-4562] SimplePriorityMessageDispatchChannel.clear() needs to reset size attribute

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 5.8.0
• Fix Version/s: 5.9.0
• Component/s: JMS client
• Patch Info: Patch Available
• Assignee: Timothy A. Bish
• Reporter: Torsten Mielke
• Created: 30/May/13 08:34
• Updated: 30/May/13 14:29
• Resolved: 30/May/13 14:29

Description

SimplePriorityMessageDispatchChannel.clear() deletes all prefetched messages but does not reset the size counter. The other method removeAll() does it correctly.

Propose to fix this as follows:

SimplePriorityMessageDispatchChannel.java

    public void clear() {
        synchronized (mutex) {
            for (int i = 0; i < MAX_PRIORITY; i++) {
                lists[i].clear();
            }
	    size = 0;
        }
    }