activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r613874 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java
Date Mon, 21 Jan 2008 13:09:39 GMT
Author: rajdavies
Date: Mon Jan 21 05:09:38 2008
New Revision: 613874

URL: http://svn.apache.org/viewvc?rev=613874&view=rev
Log:
Fix for https://issues.apache.org/activemq/browse/AMQ-1560

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java?rev=613874&r1=613873&r2=613874&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java
Mon Jan 21 05:09:38 2008
@@ -70,7 +70,7 @@
         throw new RuntimeException("Use addMessageReference instead");
     }
 
-    public void addMessageReference(final ConnectionContext context, final MessageId messageId,
+    public synchronized void addMessageReference(final ConnectionContext context, final MessageId
messageId,
                                     final ReferenceData data) {
         final ReferenceRecord record = new ReferenceRecord(messageId.toString(), data);
         final int subscriberCount = subscriberMessages.size();



Mime
View raw message