activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r499169 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java
Date Tue, 23 Jan 2007 22:38:13 GMT
Author: rajdavies
Date: Tue Jan 23 14:38:12 2007
New Revision: 499169

URL: http://svn.apache.org/viewvc?view=rev&rev=499169
Log:
add synchronize around add() - see http://www.nabble.com/Is-anyone-else-seeing-messages-stuck-on-a-queue--tf3027911.html#a8550623

Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java?view=diff&rev=499169&r1=499168&r2=499169
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java
Tue Jan 23 14:38:12 2007
@@ -57,7 +57,7 @@
     synchronized public void gc() {
     }
 
-    public void add(ConnectionContext context, Destination destination) throws Exception
{
+    public synchronized void add(ConnectionContext context, Destination destination) throws
Exception {
         super.add(context, destination);
         destinations.put(destination.getActiveMQDestination(), destination);
         if( active || keepDurableSubsActive ) {



Mime
View raw message