activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r488783 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/VMPendingMessageCursor.java
Date Tue, 19 Dec 2006 19:41:42 GMT
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());
     }
 }



Mime
View raw message