Author: timfox
Date: 2010-06-08 09:06:29 -0400 (Tue, 08 Jun 2010)
New Revision: 9302
Modified:
trunk/src/main/org/hornetq/core/server/impl/ServerConsumerImpl.java
Log:
https://jira.jboss.org/browse/HORNETQ-410
Modified: trunk/src/main/org/hornetq/core/server/impl/ServerConsumerImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/server/impl/ServerConsumerImpl.java 2010-06-08
12:46:40 UTC (rev 9301)
+++ trunk/src/main/org/hornetq/core/server/impl/ServerConsumerImpl.java 2010-06-08
13:06:29 UTC (rev 9302)
@@ -85,7 +85,7 @@
private final Object lock = new Object();
- private AtomicInteger availableCredits = new AtomicInteger(0);
+ private volatile AtomicInteger availableCredits = new AtomicInteger(0);
private boolean started;