You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2006/12/19 20:41:42 UTC
svn commit: r488783 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/VMPendingMessageCursor.java
Author: rajdavies
Date: Tue Dec 19 11:41:41 2006
New Revision: 488783
URL: http://svn.apache.org/viewvc?view=rev&rev=488783
Log:
remove println messages from remove()
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/VMPendingMessageCursor.java
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/VMPendingMessageCursor.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/VMPendingMessageCursor.java?view=diff&rev=488783&r1=488782&r2=488783
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/VMPendingMessageCursor.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/VMPendingMessageCursor.java Tue Dec 19 11:41:41 2006
@@ -94,18 +94,13 @@
list.clear();
}
- public void remove(MessageReference node) {
- boolean matched = false;
- int size = list.size();
- 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())){
- i.remove();
- matched = true;
- break;
- }
+ public void remove(MessageReference node){
+ for(Iterator i=list.iterator();i.hasNext();){
+ MessageReference ref=(MessageReference)i.next();
+ if(node.getMessageId().equals(ref.getMessageId())){
+ i.remove();
+ break;
+ }
}
- System.err.println("REMOVED " + node.getMessageId() + " = " + matched + " presize = " + size + " size now = " + list.size());
}
}