Return-Path: Delivered-To: apmail-activemq-dev-archive@www.apache.org Received: (qmail 63910 invoked from network); 20 Mar 2009 14:29:14 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 20 Mar 2009 14:29:14 -0000 Received: (qmail 22487 invoked by uid 500); 20 Mar 2009 14:29:13 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 22465 invoked by uid 500); 20 Mar 2009 14:29:13 -0000 Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list dev@activemq.apache.org Received: (qmail 22454 invoked by uid 99); 20 Mar 2009 14:29:13 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 20 Mar 2009 07:29:13 -0700 X-ASF-Spam-Status: No, hits=-1999.8 required=10.0 tests=ALL_TRUSTED,WHOIS_MYPRIVREG X-Spam-Check-By: apache.org Received: from [140.211.11.140] (HELO brutus.apache.org) (140.211.11.140) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 20 Mar 2009 14:29:04 +0000 Received: from brutus (localhost [127.0.0.1]) by brutus.apache.org (Postfix) with ESMTP id 3EAD4234C4A8 for ; Fri, 20 Mar 2009 07:28:43 -0700 (PDT) Message-ID: <512780027.1237559323255.JavaMail.jira@brutus> Date: Fri, 20 Mar 2009 07:28:43 -0700 (PDT) From: "Torsten Mielke (JIRA)" To: dev@activemq.apache.org Subject: [jira] Commented: (AMQ-2009) Problem with message dispatch after a while In-Reply-To: <1503857571.1227225545425.JavaMail.jira@brutus> MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: ae95407df07c98740808b2ef9da0087c X-Virus-Checked: Checked by ClamAV on apache.org [ https://issues.apache.org/activemq/browse/AMQ-2009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=50709#action_50709 ] Torsten Mielke commented on AMQ-2009: ------------------------------------- I also took the second test case DispatchMultipleConsumersTest.java and wrapped it in a maven JUnit project (see AMQ-2009Testcase2.zip) to run it more quickly. I first tested against version 5.3 and did not reproduce any errors. The JUnit test succeeded many times (even under a higher load than initially implemented). When testing against version 5.1 I did reproduce the duplicate message problem AMQ-2020 but not this bug! So that exhausts the two testcases we have so far. I have not been able to reproduce this issue. Has anyone else who commented on this bug tried version 5.3 yet? What are the results? > Problem with message dispatch after a while > ------------------------------------------- > > Key: AMQ-2009 > URL: https://issues.apache.org/activemq/browse/AMQ-2009 > Project: ActiveMQ > Issue Type: Bug > Components: Broker > Affects Versions: 5.1.0, 5.2.0 > Reporter: Rajani Chennamaneni > Assignee: Rob Davies > Priority: Blocker > Attachments: AMQ-2009Testcase2.zip, consumertest.zip, DispatchMultipleConsumersTest.java, JConsole-screenshot.jpg, testcase.zip > > > Messages are not getting dispatched after a while (although it accepts new incoming messages) until restart of the broker. This problem is described in several posts. > http://www.nabble.com/Pending-Messages-are-shown-in-ActiveMQ-td20241332.html > http://www.nabble.com/Consumer-Listener-stop-receving-message-until-ActiveMQ-restart-td20355247.html > http://www.nabble.com/Stuck-messages---Dispatch-issues-td20467949.html > There was also an issue opened in Spring project for this thinking it was Spring problem. > http://jira.springframework.org/browse/SPR-5110 > I am not able to reproduce with Junit test case having BrokerService started with in the test case. I guess I am not hitting the right stress conditions this way. But when I run the test case against an externally running ActiveMQ instance backed with oracle database persistence, it is reproducible most of the times. This is not a every time failure situation, it takes more time once than the other. > I was able to hit this situation of stuck messages on queue using following scenario most of the times: > 1) Start 2 concurrent consumers for the queue using Spring's DefaultMessageListenerContainer using cacheLevelName as CACHE_CONSUMER > 2) Send messages using JMETER 2.3.2 to the queue on ActiveMQ stand alone broker instance with 50 threads looping 20 times. > 3) After a while, you will notice that Spring logs that no messages are being received but the messages are shown jconsole of ActiveMQ and the database backing it for persistence. > But in 5.2 RC3, the problem is that it dispatches duplicate messages and does not remove them from broker's database after acknowledge properly. > Attached test case might help to reproduce when run against externally running stand alone ActiveMQ broker. Another way to see the problem is that try to load test using JMETER by sending messages to a queue with a camel route that moves messages from this queue to another and you will notice that it stops moving after while or copied duplicates in case of 5.2 RC3. > Sorry about such a huge description but it is a real problem! A different team at our company are having this issue in production with 5.1. They are using it as an embedded broker with derby for persistence. -- This message is automatically generated by JIRA. - You can reply to this email to add a comment to the issue online.