svn commit: r488783 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/VMPendingMessageCursor.java

[rajdavies]

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());
     }
 }