BasicQueue has ConcurrentHashMap entrySet problem

public void removeAllMessages() throws JMSException
{
boolean trace = log.isTraceEnabled();
if (trace)
log.trace("removeAllMessages " + this);

// Drop scheduled messages
for (Iterator i = events.entrySet().iterator(); i.hasNext()
{
Map.Entry entry = (Map.Entry) i.next();
MessageReference message = (MessageReference) entry.getKey();
Timeout timeout = (Timeout) entry.getValue();

timeout could be null

See also clearEvents