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

remove println messages from remove() 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@488783 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2006-12-19 19:41:41 +00:00
parent 419ed2ee91
commit f6972ec84a
1 changed files with 7 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/VMPendingMessageCursor.java
View File

@ -94,18 +94,13 @@ public class VMPendingMessageCursor extends AbstractPendingMessageCursor{
list.clear(); list.clear();
} }
public void remove(MessageReference node) { public void remove(MessageReference node){
boolean matched = false; for(Iterator i=list.iterator();i.hasNext();){
int size = list.size(); MessageReference ref=(MessageReference)i.next();
for (Iterator i = list.iterator();i.hasNext();) {
MessageReference ref = (MessageReference)i.next();
System.err.println("MATCHIG " + node.getMessageId() + " AGAINST " + ref.getMessageId());
if(node.getMessageId().equals(ref.getMessageId())){ if(node.getMessageId().equals(ref.getMessageId())){
i.remove(); i.remove();
matched = true;
break; break;
} }
} }
System.err.println("REMOVED " + node.getMessageId() + " = " + matched + " presize = " + size + " size now = " + list.size());
} }
} }