Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 85318 invoked from network); 24 Mar 2008 18:57:30 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 24 Mar 2008 18:57:30 -0000 Received: (qmail 52948 invoked by uid 500); 24 Mar 2008 18:57:29 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 52928 invoked by uid 500); 24 Mar 2008 18:57:29 -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 52919 invoked by uid 99); 24 Mar 2008 18:57:29 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 24 Mar 2008 11:57:29 -0700 X-ASF-Spam-Status: No, hits=2.0 required=10.0 tests=HTML_MESSAGE,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of andrew@oc384.net designates 204.80.187.5 as permitted sender) Received: from [204.80.187.5] (HELO mail1.ykwc.com) (204.80.187.5) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 24 Mar 2008 18:56:39 +0000 Received: from box2 (brandtllc.com [66.17.204.66]) by mail1.ykwc.com (Postfix) with ESMTPA id 2465BAB4AD for ; Mon, 24 Mar 2008 11:56:54 -0700 (PDT) From: "Andrew M" To: Subject: setting a MessageListener on a consumer? Date: Mon, 24 Mar 2008 13:56:30 -0500 Message-ID: <027a01c88de0$c5df0fe0$519d2fa0$@net> MIME-Version: 1.0 Content-Type: multipart/alternative; boundary="----=_NextPart_000_027B_01C88DB6.DD0907E0" X-Mailer: Microsoft Office Outlook 12.0 Thread-Index: AciN4MVQPhj87XpXRTWXlE9e/4Irew== Content-Language: en-us X-YKWC-MailScanner-Information: Please contact Yellowknife for more information X-MailScanner-ID: 2465BAB4AD.B8BBB X-YKWC-MailScanner: Found to be clean X-YKWC-MailScanner-SpamCheck: not spam, SpamAssassin (not cached, score=-4.398, required 5, autolearn=not spam, ALL_TRUSTED -1.80, BAYES_00 -2.60, HTML_MESSAGE 0.00) X-Virus-Checked: Checked by ClamAV on apache.org X-Old-Spam-Status: No ------=_NextPart_000_027B_01C88DB6.DD0907E0 Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: 7bit I'm using the method below to create a Topic and Consumer and register my MessageListener. I'm worried that with a retroactive consumer I'm missing messages between the .createConsumer() method and when the MessageListener is actually registered with the MessageConsumer. Shouldn't there be some way to set the listener before firing up the consumer? public void subscribe(String destName, MessageListener l) throws JMSException { char c = destName.contains("?")?'&':'?'; destName = destName + c + "consumer.retroactive=true"; System.out.println("ActiveMqClient subscribe " + destName); MessageConsumer mc = session.createConsumer( session.createTopic(destName) ); mc.setMessageListener(l); } Thanks, Andrew ------=_NextPart_000_027B_01C88DB6.DD0907E0--