Return-Path: Delivered-To: apmail-geronimo-activemq-commits-archive@www.apache.org Received: (qmail 42156 invoked from network); 19 Dec 2006 19:42:31 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 19 Dec 2006 19:42:31 -0000 Received: (qmail 20214 invoked by uid 500); 19 Dec 2006 19:42:39 -0000 Delivered-To: apmail-geronimo-activemq-commits-archive@geronimo.apache.org Received: (qmail 20193 invoked by uid 500); 19 Dec 2006 19:42:39 -0000 Mailing-List: contact activemq-commits-help@geronimo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: activemq-dev@geronimo.apache.org Delivered-To: mailing list activemq-commits@geronimo.apache.org Received: (qmail 20184 invoked by uid 99); 19 Dec 2006 19:42:39 -0000 Received: from herse.apache.org (HELO herse.apache.org) (140.211.11.133) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 19 Dec 2006 11:42:39 -0800 X-ASF-Spam-Status: No, hits=-9.4 required=10.0 tests=ALL_TRUSTED,NO_REAL_NAME X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO eris.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 19 Dec 2006 11:42:30 -0800 Received: by eris.apache.org (Postfix, from userid 65534) id 83D821A981A; Tue, 19 Dec 2006 11:41:42 -0800 (PST) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit 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 -0000 To: activemq-commits@geronimo.apache.org From: rajdavies@apache.org X-Mailer: svnmailer-1.1.0 Message-Id: <20061219194142.83D821A981A@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org 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()); } }