Author: clebert.suconic(a)jboss.com
Date: 2011-02-15 19:07:02 -0500 (Tue, 15 Feb 2011)
New Revision: 10211
Modified:
branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/impl/ScheduledDeliveryHandlerImpl.java
Log:
tweak
Modified:
branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/impl/ScheduledDeliveryHandlerImpl.java
===================================================================
---
branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/impl/ScheduledDeliveryHandlerImpl.java 2011-02-15
22:33:01 UTC (rev 10210)
+++
branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/impl/ScheduledDeliveryHandlerImpl.java 2011-02-16
00:07:02 UTC (rev 10211)
@@ -195,7 +195,11 @@
for (MessageReference reference : references)
{
- reference.getQueue().addTail(reference);
+ Queue queue = reference.getQueue();
+ synchronized (queue)
+ {
+ queue.addTail(reference);
+ }
}
// Just to speed up GC
Show replies by date