From users-return-19318-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org Mon Jun 08 13:40:30 2009 Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 97545 invoked from network); 8 Jun 2009 13:40:30 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 8 Jun 2009 13:40:30 -0000 Received: (qmail 48513 invoked by uid 500); 8 Jun 2009 13:40:42 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 48493 invoked by uid 500); 8 Jun 2009 13:40:42 -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 48483 invoked by uid 99); 8 Jun 2009 13:40:42 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 08 Jun 2009 13:40:42 +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: local policy) Received: from [213.239.154.11] (HELO adonis.tweakers.net) (213.239.154.11) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 08 Jun 2009 13:40:31 +0000 Received: from localhost (localhost [127.0.0.1]) by adonis.tweakers.net (Postfix) with ESMTP id AD52F5DC372 for ; Mon, 8 Jun 2009 15:40:09 +0200 (CEST) Received: from adonis.tweakers.net ([127.0.0.1]) by localhost (adonis.tweakers.net [127.0.0.1]) (amavisd-maia, port 10024) with ESMTP id 07307-09 for ; Mon, 8 Jun 2009 15:40:06 +0200 (CEST) Received: from groupware.tweakers.net (groupware.tweakers.net [87.233.197.175]) by adonis.tweakers.net (Postfix) with ESMTP id 5B97B5DC370 for ; Mon, 8 Jun 2009 15:40:06 +0200 (CEST) X-MDAV-Processed: groupware.tweakers.net, Mon, 08 Jun 2009 15:40:03 +0200 Received: from [10.0.0.153] by groupware.tweakers.net (Cipher TLSv1:RC4-MD5:128) (MDaemon PRO v10.0.5) with ESMTP id md50000141749.msg for ; Mon, 08 Jun 2009 15:40:02 +0200 X-Spam-Processed: groupware.tweakers.net, Mon, 08 Jun 2009 15:40:02 +0200 (not processed: spam filter heuristic analysis disabled) X-Return-Path: acmmailing@tweakers.net X-Envelope-From: acmmailing@tweakers.net X-MDaemon-Deliver-To: users@activemq.apache.org Message-ID: <4A2D14B3.6070806@tweakers.net> Date: Mon, 08 Jun 2009 15:40:03 +0200 From: Arjen van der Meijden User-Agent: Thunderbird 2.0.0.21 (Windows/20090302) MIME-Version: 1.0 To: users@activemq.apache.org Subject: Consumers newer than messages don't receive messages from queues Content-Type: text/plain; charset=ISO-8859-1; format=flowed Content-Transfer-Encoding: 7bit X-Virus-Scanned: Maia Mailguard 1.0.2 X-Virus-Checked: Checked by ClamAV on apache.org Hello list, In a somewhat complicated set of consumption-processing, I have three queues. One to indicate a new job, which is consumed by a single long-running consumer that sends messages to a second queue. That second queue is consumed by four consumers that kill themselves after having processed a (few) message(s). After each message from the second queue is processed, they're send to a third queue which has two similar consumers. As soon as such a consumer exits, a control process starts a new consumer, to have a fixed amount of consumers. The jobs for the initial queue are issued in batches, so there can be a burst of about 150 messages, resulting in a burst in the second queue. As soon as those second-queue-consumers exit however, they don't consume much messages. Most of the time it seems that only one is actually doing any work and the other three are idle, even if the queue has more than 100 messages. The same holds for the third-queue-consumers. It seems to have to do with the fact that those consumers actually subscribe to the queue after the messages have been produced. Obviously, I want them to start consuming a message as soon as they connect. All message production and consumption is via Stomp in PHP and the ActiveMQ is a 5.2.0-version with mostly a default configuration. I have tried to see if subscribing using the headers 'activemq.retroactive' and 'activemq.dispatchAsync' set to 'true' make any difference, but that doesn't seem to do anything. Anyone knows what's going on and how to fix it? Best regards, Arjen