Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 42165 invoked from network); 4 May 2007 00:33:46 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 4 May 2007 00:33:46 -0000 Received: (qmail 49410 invoked by uid 500); 4 May 2007 00:33:52 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 49393 invoked by uid 500); 4 May 2007 00:33:52 -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 49384 invoked by uid 99); 4 May 2007 00:33:51 -0000 Received: from herse.apache.org (HELO herse.apache.org) (140.211.11.133) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 03 May 2007 17:33:51 -0700 X-ASF-Spam-Status: No, hits=-0.0 required=10.0 tests=SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (herse.apache.org: domain of jlim@exist.com designates 209.235.254.11 as permitted sender) Received: from [209.235.254.11] (HELO exodus.exist.com) (209.235.254.11) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 03 May 2007 17:33:44 -0700 Received: from [192.168.241.198] (tequilla.exist.com [58.71.14.245]) (authenticated bits=0) by exodus.exist.com (8.13.1/8.13.1) with ESMTP id l440XDlY023932 (version=TLSv1/SSLv3 cipher=DHE-RSA-AES256-SHA bits=256 verify=NO) for ; Thu, 3 May 2007 20:33:17 -0400 Message-ID: <463A7F4C.4090208@exist.com> Date: Fri, 04 May 2007 08:33:16 +0800 From: Jonas Lim User-Agent: Thunderbird 1.5.0.10 (Windows/20070221) MIME-Version: 1.0 To: users@activemq.apache.org Subject: Re: Creating simple producer and consumer References: <10294868.post@talk.nabble.com> <46394A65.3060504@exist.com> <10303400.post@talk.nabble.com> <10309773.post@talk.nabble.com> <10310875.post@talk.nabble.com> In-Reply-To: <10310875.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 For topics the consumer must be created first since messages are only delivered to the available consumers at the time the broker receives the message. For durable subscribers you can create a durable subscriber, kill it, run the producer, then start the subscriber again. http://java.sun.com/j2ee/1.4/docs/api/javax/jms/Session.html#createDurableSubscriber(javax.jms.Topic,%20java.lang.String) http://activemq.apache.org/how-does-a-queue-compare-to-a-topic.html Regards, Jonas Bai Shen wrote: > > Bai Shen wrote: > >> >> James.Strachan wrote: >> >>> Try looking at the queues & consumers in the broker >>> http://activemq.apache.org/how-can-i-monitor-activemq.html >>> >>> -- >>> James >>> ------- >>> http://macstrac.blogspot.com/ >>> >>> >>> >> I can see the topic in the console and the Enqueue Count shows my >> messages. But I can't seem to receive them for some reason. >> >> > > Okay, I ended up changing from a Topic to a Queue and was able to send and > receive my messages asynch. However, I still don't quite understand the > durable part. I've read > http://activemq.apache.org/how-do-durable-queues-and-topics-work.html but > AFAIK, the PERSISTANT flag is 'sposed to be already on. I even set it, and > I still wasn't able to get things to work. >