Return-Path: X-Original-To: apmail-qpid-users-archive@www.apache.org Delivered-To: apmail-qpid-users-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 9A07D11F31 for ; Wed, 27 Aug 2014 07:52:00 +0000 (UTC) Received: (qmail 94524 invoked by uid 500); 27 Aug 2014 07:52:00 -0000 Delivered-To: apmail-qpid-users-archive@qpid.apache.org Received: (qmail 94485 invoked by uid 500); 27 Aug 2014 07:52:00 -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 94463 invoked by uid 99); 27 Aug 2014 07:51:59 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 27 Aug 2014 07:51:59 +0000 X-ASF-Spam-Status: No, hits=2.8 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS,URI_HEX X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of rob.j.godfrey@gmail.com designates 209.85.216.174 as permitted sender) Received: from [209.85.216.174] (HELO mail-qc0-f174.google.com) (209.85.216.174) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 27 Aug 2014 07:51:56 +0000 Received: by mail-qc0-f174.google.com with SMTP id l6so16559494qcy.5 for ; Wed, 27 Aug 2014 00:51:35 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=IlqptaVP53V7hipENbO24+rKcZwSrYuMwR/424q6wZ4=; b=MCjBgfl3XPbrVj0bDJACoHdtydvaVe7VAgC677Xow3UIGxRl2Heh/KtIWjMD87BGjn +kY4RKJcDVqy3BnXpjIdvKfMjDaLg8JF978kHJSfoaNHSkbH+cyCjlXxcE6SKA5ezKli N7NZDGCyb+DtP5TB1PCgBsMKowugt9LCMc3ab87WYjpLr7V9gehyv+G7s0w7nSlmo98x ikFY1Zxb087aBgebStQNEwKBJ0GpHRWRCS6HDKNMnernNBZebCGzX3EVuwOTm2105jjX TBpaL4GKt1Nj7SQmLgYQGssp8oTku75dU7CVTJEoBsnueWglveq3vPLDaAUh4Ew7qPDp MpNg== MIME-Version: 1.0 X-Received: by 10.224.47.6 with SMTP id l6mr55390788qaf.32.1409125895368; Wed, 27 Aug 2014 00:51:35 -0700 (PDT) Received: by 10.140.101.6 with HTTP; Wed, 27 Aug 2014 00:51:35 -0700 (PDT) In-Reply-To: <1409099599208-7612615.post@n2.nabble.com> References: <1408777758772-7612411.post@n2.nabble.com> <1409099599208-7612615.post@n2.nabble.com> Date: Wed, 27 Aug 2014 09:51:35 +0200 Message-ID: Subject: Re: 1 Queue with 2 Consumers - turn off pre-fetching? From: Rob Godfrey To: "users@qpid.apache.org" Content-Type: multipart/alternative; boundary=001a11c2c7e46ff8be050197b0ea X-Virus-Checked: Checked by ClamAV on apache.org --001a11c2c7e46ff8be050197b0ea Content-Type: text/plain; charset=UTF-8 On 27 August 2014 02:33, xiaodan.wang wrote: > Hi Rob, just verified with 0.32/trunk client and the v0.16 broker that we > currently use. It is indeed doing prefetching at a per session level once I > started the client with AMQP 0-91. Thanks so much for the suggestion! Great! > The > only issue I encountered is that getJMSDestination on the message returns > an > instance of AMQTopic instead of javax.jms.Queue object, which was > straightforward to work around. Can you give me an example of the sort of address that you set the replyTo to - I'll try to look into this and fix it before the 0.30 release goes out > Did not encounter any other issues between > 0.32 client/0.16 broker so far, *fingers-crossed*. > > Long term, we would definitely be interested in updating the broker to test > out the multiple queue per consumer feature you are adding to trunk > considering our options with AMQP 0-10 is non-existent at the moment. > > Couple of quick questions: > > 1) Did session-level prefetching get dropped as part of changes to the > protocol from AMQP 0-91 -> AMQP 0-10? > > Yes - it's a change at the underlying protocol level. If you are interested in all the gory details, the 0-9-1 specification is here: http://www.amqp.org/specification/0-9-1/amqp-org-download and the 0-10 specification is here http://www.amqp.org/specification/0-10/amqp-org-download In 0-9-1 flow control is enforced through the basic.qos method which allows you to set a prefetch size (in terms of either bytes or messages). In 0-10 flow control is enforced through the message.flow command which is on a per subscription basis. > 2) Is there any plans to drop support on the broker for versions below AMQP > 0-10? > > Absolutely not! We have a large number of users using 0-8 / 0-9 / 0-9-1. The aim for the Java Broker is to support every publicly released version of AMQP and allow interoperation between these versions as much as possible. The 0.30 broker release provides some enhancements both to 0-9-1 functionality and message conversions between 0-9-1 and the other AMQP protocols. Hope this helps, Rob > Thanks! > > > > -- > View this message in context: > http://qpid.2158936.n2.nabble.com/Re-1-Queue-with-2-Consumers-turn-off-pre-fetching-tp6934582p7612615.html > Sent from the Apache Qpid users mailing list archive at Nabble.com. > > --------------------------------------------------------------------- > To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org > For additional commands, e-mail: users-help@qpid.apache.org > > --001a11c2c7e46ff8be050197b0ea--