activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r504999 [2/2] - in /activemq/trunk/activemq-core/src/main/java/org/apache/activemq: kaha/ kaha/impl/container/ kaha/impl/index/hash/ store/ store/amq/ store/kahadaptor/
Date Thu, 08 Feb 2007 18:46:56 GMT
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?view=diff&rev=504999&r1=504998&r2=504999
==============================================================================
--- 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
Thu Feb  8 10:46:54 2007
@@ -75,6 +75,7 @@
         int subscriberCount=subscriberMessages.size();
         if(subscriberCount>0){
             StoreEntry messageEntry=messageContainer.place(messageId,record);
+            addInterest(record);
             TopicSubAck tsa=new TopicSubAck();
             tsa.setCount(subscriberCount);
             tsa.setMessageEntry(messageEntry);
@@ -129,7 +130,11 @@
                 if(tsa!=null){
                     if(tsa.decrementCount()<=0){
                         ackContainer.remove(ref.getAckEntry());
+                        ReferenceRecord rr = messageContainer.get(messageId);
+                        if (rr != null) {
                         messageContainer.remove(tsa.getMessageEntry());
+                        removeInterest(rr);
+                        }
                     }else{
                         ackContainer.update(ref.getAckEntry(),tsa);
                     }



Mime
View raw message