Return-Path: Delivered-To: apmail-qpid-users-archive@www.apache.org Received: (qmail 41636 invoked from network); 9 Mar 2011 20:28:53 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 9 Mar 2011 20:28:53 -0000 Received: (qmail 22715 invoked by uid 500); 9 Mar 2011 20:28:53 -0000 Delivered-To: apmail-qpid-users-archive@qpid.apache.org Received: (qmail 22647 invoked by uid 500); 9 Mar 2011 20:28:53 -0000 Mailing-List: contact users-help@qpid.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@qpid.apache.org Delivered-To: mailing list users@qpid.apache.org Received: (qmail 22639 invoked by uid 99); 9 Mar 2011 20:28:53 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 09 Mar 2011 20:28:53 +0000 X-ASF-Spam-Status: No, hits=3.7 required=5.0 tests=FREEMAIL_ENVFROM_END_DIGIT,FREEMAIL_FROM,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of rajith77@gmail.com designates 74.125.82.170 as permitted sender) Received: from [74.125.82.170] (HELO mail-wy0-f170.google.com) (74.125.82.170) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 09 Mar 2011 20:28:45 +0000 Received: by wyb34 with SMTP id 34so1168422wyb.15 for ; Wed, 09 Mar 2011 12:28:25 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:mime-version:in-reply-to:references:date :message-id:subject:from:to:cc:content-type; bh=Pc5v4gvziGIpZobpCxqMpF8qoJ5G5vdvdvb61cj5vVo=; b=W/6Gl/33udVkQAJ0TB8yglkJ5Fg3I4c3j9UFx1SANwqmKZgQBmoF+Q28IreCkmr5gS 435kk8TeTfwPlNIXt8glxp/Q26swCuXnfbj4SUabhWodMXrWKnaERkMcuype3BzBETeN JxbfPazOKEVCPOmx3HyLmLkH21NqTIV0uhz+c= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :cc:content-type; b=uBvqeXLXXhb9k1ZOVhC8MXt0O8cxwqq8ZteY+nm64WFhFj7g4C2CEPyfgnvbj+MFWL Pzz5plQrf0ETqLOiH3qDw32wILtGSqZzk0VVAMPTK7CCMf8W/rDMD587UTuYzqTJizKd cv5GXJxb1fuD6BTyExEi8jC1PJIQ2fyEi22xI= MIME-Version: 1.0 Received: by 10.227.165.194 with SMTP id j2mr6182867wby.178.1299702505177; Wed, 09 Mar 2011 12:28:25 -0800 (PST) Received: by 10.227.146.201 with HTTP; Wed, 9 Mar 2011 12:28:25 -0800 (PST) In-Reply-To: References: Date: Wed, 9 Mar 2011 15:28:25 -0500 Message-ID: Subject: Re: onMessage() always acknowledges msg even if Session is set to CLIENT_ACK From: Rajith Attapattu To: users@qpid.apache.org Cc: Kim Garcia Content-Type: multipart/alternative; boundary=90e6ba4768d9228494049e12923d X-Virus-Checked: Checked by ClamAV on apache.org --90e6ba4768d9228494049e12923d Content-Type: text/plain; charset=ISO-8859-1 On Wed, Mar 9, 2011 at 2:47 PM, Kim Garcia wrote: > > Hi Rajith, > > It doesn't matter if the apps are consumers or queue browsers as long as > they share the messages (or get their own copy). > > I'm looking into using the javax.jms Topic object as suggested, but do the > messages have to be sent to a topic instead of a queue? If so, then that > won't work for me. I have messages being sent to an AMQ queue, and at this > time, that cannot change. > What exactly did you mean by AMQ queue here ? Can you give an example of how the address for that sender looks like ? The Queues and Topics I am referring to here are as how JMS describes them. Please note that Queues doesn't correspond to amq.direct exchange and Topics doesn't mean you have to use amq.topic exchange. If you could answer my above questions and also describe your use case in a bit more detail, then I should be able to give you some precise instructions. Regards, Rajith > > Thanks, > Kim > > > ---------------------------------------------------------------------------------------------------------------- > > The answer below is assuming that all your apps are consumers and not queue > browsers. > If thats not the case then please let me know. > > Rajith > > On Wed, Mar 9, 2011 at 9:53 AM, Rajith Attapattu > wrote: > > > Kim, > > > > If you want all the apps (consumers) on the same queue to get all the > > messages in the queue, then using 'Queues (as in JMS terms)' is not going > > to do it. > > As in a shared queue situation the messages will be distributed among > them. > > > > Therefore you should use a Topic and all your consumers will get a copy > of > > every message sent to that topic. > > > > Regards, > > > > Rajith > > > > > > On Wed, Mar 9, 2011 at 12:05 AM, Kim Garcia wrote: > > > >> > >> Rajith, > >> > >> I have been trying to respond to your email all day but Hotmail keeps > >> saying the delivery has failed... > >> > >> > >> > ---------------------------------------------------------------------------------------------------------------------------- > >> > >> Thank you for looking into this, Rajith. > >> > >> I'm not using any > >> tools to verify if the message has been acked. I am running 2 of the > >> same Java application. If I only run one, then it will get the messages > >> like normal. If I run 2, they do not both get the same messages. I see > >> that if app #1 gets message #1, then app #2 will not get message #1. The > >> same applies for messages app #2 gets -- app #1 will not get them. I > >> would like several apps to monitor the same queue with a listener and > >> for all apps to get all of the messages. > >> > >> Thanks. > >> > >> > Date: Mon, 7 Mar 2011 18:07:19 -0500 > >> > Subject: Re: onMessage() always acknowledges msg even if Session is > set > >> to CLIENT_ACK > > --90e6ba4768d9228494049e12923d--