From users-return-1645-apmail-qpid-users-archive=qpid.apache.org@qpid.apache.org Mon Jul 13 11:28:17 2009 Return-Path: Delivered-To: apmail-qpid-users-archive@www.apache.org Received: (qmail 29451 invoked from network); 13 Jul 2009 11:28:17 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 13 Jul 2009 11:28:17 -0000 Received: (qmail 21290 invoked by uid 500); 13 Jul 2009 11:28:26 -0000 Delivered-To: apmail-qpid-users-archive@qpid.apache.org Received: (qmail 21266 invoked by uid 500); 13 Jul 2009 11:28:26 -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 21256 invoked by uid 99); 13 Jul 2009 11:28:26 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 13 Jul 2009 11:28:26 +0000 X-ASF-Spam-Status: No, hits=-4.0 required=10.0 tests=RCVD_IN_DNSWL_MED,SPF_HELO_PASS,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of gsim@redhat.com designates 66.187.233.31 as permitted sender) Received: from [66.187.233.31] (HELO mx1.redhat.com) (66.187.233.31) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 13 Jul 2009 11:28:17 +0000 Received: from int-mx1.corp.redhat.com (int-mx1.corp.redhat.com [172.16.52.254]) by mx1.redhat.com (8.13.8/8.13.8) with ESMTP id n6DBRt7e004818 for ; Mon, 13 Jul 2009 07:27:55 -0400 Received: from pobox.fab.redhat.com (pobox.fab.redhat.com [10.33.63.12]) by int-mx1.corp.redhat.com (8.13.1/8.13.1) with ESMTP id n6DBRsht004475 for ; Mon, 13 Jul 2009 07:27:55 -0400 Received: from [10.11.12.90] (vpn-12-90.rdu.redhat.com [10.11.12.90]) by pobox.fab.redhat.com (8.13.1/8.13.1) with ESMTP id n6DBRr8k026000 for ; Mon, 13 Jul 2009 07:27:54 -0400 Message-ID: <4A5B1BD5.3050008@redhat.com> Date: Mon, 13 Jul 2009 12:34:45 +0100 From: Gordon Sim Organization: Registered Address: Red Hat UK Ltd, Amberley Place, 107-111 Peascod Street, Windsor, Berkshire, SI4 1TE, United Kingdom.,Registered in England and Wales under Company Registration No. 3798903,Directors: Michael Cunningham (USA), Charlie Peters (USA) and David Owens (Ireland) User-Agent: Thunderbird 1.5.0.2 (X11/20060501) MIME-Version: 1.0 To: users@qpid.apache.org Subject: Re: localqueue get References: <333440.82770.qm@web46116.mail.sp1.yahoo.com> In-Reply-To: <333440.82770.qm@web46116.mail.sp1.yahoo.com> Content-Type: text/plain; charset=ISO-8859-1; format=flowed Content-Transfer-Encoding: 7bit X-Scanned-By: MIMEDefang 2.58 on 172.16.52.254 X-Virus-Checked: Checked by ClamAV on apache.org Nithesh Shetty wrote: > the listener sample has the following settings; > SubscriptionManager subscriptions(session); > SubscriptionSettings settings; > settings.acceptMode = ACCEPT_MODE_NONE; > settings.acquireMode = ACQUIRE_MODE_PRE_ACQUIRED; > LocalQueue local_queue; > subscriptions.subscribe(local_queue, "RMS", settings, "rmsset"); > > Message message = local_queue.get(); > > %%%%%%%%%%%%%%%%%%%%%%%%%%%%% > > now the problem is if i put ten message in the queue and get one message and then close > the connection the rest of the nine message gets dequeued... ACCEPT_MODE_NONE means that the broker will dequeue the message as soon as it is delivered. As you are using the default flow control settings for your client, the broker will send as many messages to the client as it can, regardless of whether the client application has received the earlier messages. If you want the transfer from broker to subscribers to be reliable, use ACCEPT_MODE_EXPLICIT. --------------------------------------------------------------------- Apache Qpid - AMQP Messaging Implementation Project: http://qpid.apache.org Use/Interact: mailto:users-subscribe@qpid.apache.org