Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 36422 invoked from network); 20 Feb 2010 18:13:38 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 20 Feb 2010 18:13:38 -0000 Received: (qmail 23333 invoked by uid 500); 20 Feb 2010 18:13:37 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 23266 invoked by uid 500); 20 Feb 2010 18:13:37 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 23255 invoked by uid 99); 20 Feb 2010 18:13:37 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 20 Feb 2010 18:13:37 +0000 X-ASF-Spam-Status: No, hits=-0.0 required=10.0 tests=SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of rajdavies@gmail.com designates 209.85.212.43 as permitted sender) Received: from [209.85.212.43] (HELO mail-vw0-f43.google.com) (209.85.212.43) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 20 Feb 2010 18:13:28 +0000 Received: by vws18 with SMTP id 18so821567vws.2 for ; Sat, 20 Feb 2010 10:13:07 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:received:received:message-id:from:to :in-reply-to:content-type:content-transfer-encoding:mime-version :subject:date:references:x-mailer; bh=u5fYQ9mRyOltLNGjrPE9cUa0XqGwNEgo1YQG+Rct70A=; b=EDjvKCQy1XtY0mxPgeF2/M46TxPNhcRoICbOakZdAmO1bl175Qd0OG3TyQjL7nevqM wcL5NX2xqL2G7ej37I64jJZK326l7E/ZT5XMrNA971aog339QKMiouCHpdT8WIMcFWP0 zPHWl1CzYYhn9Cpwv2heZBJX96NPZlwkRPQQ4= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=message-id:from:to:in-reply-to:content-type :content-transfer-encoding:mime-version:subject:date:references :x-mailer; b=jlDGJqFXUsttmoufmezh/4+Vaw7cIIiKXSKzlmjTP2MyQV38tyWuILVvYfdh5IcdlF HlgrG3ug8QLU31M4pJRwiC8EIS769m+DqfdcSMSjxOT2LTYD64K53KViZIz4k+V+JiRR 7FflByyTI1JQj2D7DXIAt7nbN/SWzTombmb2g= Received: by 10.220.123.215 with SMTP id q23mr5589843vcr.179.1266689586763; Sat, 20 Feb 2010 10:13:06 -0800 (PST) Received: from ?192.168.1.80? ([81.147.87.190]) by mx.google.com with ESMTPS id 29sm13513745vws.3.2010.02.20.10.13.05 (version=TLSv1/SSLv3 cipher=RC4-MD5); Sat, 20 Feb 2010 10:13:05 -0800 (PST) Message-Id: From: Rob Davies To: users@activemq.apache.org In-Reply-To: <27664135.post@talk.nabble.com> Content-Type: text/plain; charset=US-ASCII; format=flowed; delsp=yes Content-Transfer-Encoding: 7bit Mime-Version: 1.0 (Apple Message framework v936) Subject: Re: Stuck messages - Dispatch issues Date: Sat, 20 Feb 2010 18:13:02 +0000 References: <20467949.post@talk.nabble.com> <27664135.post@talk.nabble.com> X-Mailer: Apple Mail (2.936) Do you still get problems if not using Spring ? On 20 Feb 2010, at 07:12, Elliot Barlas wrote: > > Was this issue ever resolved? I am seeing this as well with a large > number > of concurrent consumers. Same symptoms. Lost messages until broker > restart. > > Thanks, > Elliot > > > > chrajanirao wrote: >> >> We are seeing issues with ActiveMQ 5.1 and 5.2 RC2 with message >> dispatching from queues. It is easily reproducible even using the >> out of >> the box activemq configuration. >> >> Send messages to the a queue (QueueA) using multiple threads (10 or >> 20 >> thread in a loop of 10) using JMeter or your custom code. Have the >> consumer setup using spring DMLC (DefaultMessageListenerContainer) >> or with >> regular JMS API sync or async consumption with multiple consumers. >> Consumer part can be configured using Camel to consumer from QueueA >> and >> put the messages in QueueB within ActiveMQ configuration as well. >> >> After receiving some messages (the number is different each time), >> the >> consumers stop receiving any messages even though there are some >> left on >> the queue. Basically, the broker don't dispatch the messages and >> they are >> stuck until restart of the broker. Any new messages sent to the queue >> after this are sometimes dispatched and other times they are stuck >> too. >> >> This certainly seems like a major bug in the dispatch mechanism. I >> have >> found below posts that state the exact problem. >> >> 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 >> >> This is a very basic use case and I wonder how the version 5.1 is >> currently used in production, if anyone is using at all. >> >> We tried with prefetch limit as 1, asyncDispatch as true and false, >> session transacted as true and false. In all cases, the dispatch >> problem >> still exists starting after 100 messages until 1000 messages. >> >> I hope any of the active commiters looks into this issue seriously. >> Would >> really appreciate the help. >> >> Thanks, >> Rajani. >> > > -- > View this message in context: http://old.nabble.com/Stuck-messages---Dispatch-issues-tp20467949p27664135.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > Rob Davies http://twitter.com/rajdavies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/