Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 64229 invoked from network); 6 Jul 2007 15:45:46 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 6 Jul 2007 15:45:46 -0000 Received: (qmail 89730 invoked by uid 500); 5 Jul 2007 23:45:49 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 89704 invoked by uid 500); 5 Jul 2007 23:45:49 -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 89695 invoked by uid 99); 5 Jul 2007 23:45:49 -0000 Received: from herse.apache.org (HELO herse.apache.org) (140.211.11.133) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 05 Jul 2007 16:45:49 -0700 X-ASF-Spam-Status: No, hits=0.0 required=10.0 tests= X-Spam-Check-By: apache.org Received-SPF: neutral (herse.apache.org: local policy) Received: from [144.140.82.153] (HELO omta01ps.mx.bigpond.com) (144.140.82.153) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 05 Jul 2007 16:45:39 -0700 Received: from oaamta01ps.mx.bigpond.com ([124.176.142.120]) by omta01ps.mx.bigpond.com with ESMTP id <20070705234516.DQVR1011.omta01ps.mx.bigpond.com@oaamta01ps.mx.bigpond.com> for ; Thu, 5 Jul 2007 23:45:16 +0000 Received: from [192.168.1.100] (really [124.176.142.120]) by oaamta01ps.mx.bigpond.com with ESMTP id <20070705234515.MUUN16656.oaamta01ps.mx.bigpond.com@[192.168.1.100]> for ; Thu, 5 Jul 2007 23:45:15 +0000 Message-ID: <468D82A8.3090108@comware.com.au> Date: Fri, 06 Jul 2007 09:45:44 +1000 From: Jim Alateras Reply-To: jima@comware.com.au User-Agent: Thunderbird 2.0.0.4 (Windows/20070604) MIME-Version: 1.0 To: users@activemq.apache.org Subject: single session multiple consumers and selectors References: <11395090.post@talk.nabble.com> <11452131.post@talk.nabble.com> In-Reply-To: <11452131.post@talk.nabble.com> Content-Type: text/plain; charset=ISO-8859-1; format=flowed Content-Transfer-Encoding: 7bit X-Virus-Checked: Checked by ClamAV on apache.org I have a single session which uses two consumers all within a single thread. This is how i use them 1. consumerA simply does a receiveNoWait on the queue and pops the first message. 2. We then use the firstMessage to construct a new consumer with a specific selector, named consumerB 3. consumerB will retrieve messages of the same queue until it receives a message with an end-of-stream indicator. 4. Commit the session, which owns consumerA and consumerB It seems that the second selector never consumers any messages of the queue even though there are messages which satisfy the selector. any ideas? cheers