Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

remove System messages 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@587051 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2007-10-22 10:10:40 +00:00
parent 36486fe5b4
commit 13fc99769f
1 changed files with 0 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java
View File

@ -140,15 +140,8 @@ public class KahaTopicReferenceStore extends KahaReferenceStore implements Topic
messageContainer.remove(entry); messageContainer.remove(entry);
removeInterest(rr); removeInterest(rr);
removeMessage = true; removeMessage = true;
}else {
System.err.println("REF RTEC OS NULL!!!");
} }
} else {
System.out.println("RED XOUVT IAS " + tsa.getCount());
ackContainer.update(ref.getAckEntry(), tsa);
} }
}else{
System.err.println("NO TAS!!!");
} }
}else{ }else{
//no message held //no message held