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 F05B2C3E2 for ; Fri, 27 Apr 2012 12:42:27 +0000 (UTC) Received: (qmail 42501 invoked by uid 500); 27 Apr 2012 12:42:27 -0000 Delivered-To: apmail-qpid-users-archive@qpid.apache.org Received: (qmail 42469 invoked by uid 500); 27 Apr 2012 12:42:27 -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 42461 invoked by uid 99); 27 Apr 2012 12:42:27 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 27 Apr 2012 12:42:27 +0000 X-ASF-Spam-Status: No, hits=-0.7 required=5.0 tests=RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of rob.j.godfrey@gmail.com designates 74.125.82.170 as permitted sender) Received: from [74.125.82.170] (HELO mail-we0-f170.google.com) (74.125.82.170) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 27 Apr 2012 12:42:21 +0000 Received: by werh12 with SMTP id h12so457179wer.15 for ; Fri, 27 Apr 2012 05:42:01 -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:content-transfer-encoding; bh=K4NcEcdw1amBEyAioy8piP72Erdy1LkC6jCiJGygAVw=; b=UaR8OkIv2UzroW/T2tZOGQ2WX0113DJOz7fhB/BGhqpT+WtUmrvLkJZIzyXgLTw0ws vCro/mjYYJcX1rnBFeh1vh+22iTNxIph445oJ1nOUJr8yAZmzGkknnzwZlyqVhRbGrk3 NFbQ+P+7iku9vKNyo5JK0OevaUeJgH9WxPYSO9tHlStu/JWt/Dyhgk4DSsrLxEHIQFAi 9pXikIlx7e0ZsXOSA8Rl1AEUZTX+rFVyjuZmeu4LNBSR5qXChM8er2PSzr9ZwvRk1lf2 qi5MDvHWCRSGootOLvAAmW77O58Bs1h0lAEu/oDG/J/kWKEHd1xi6JW4Iajk3PL6w+dz MVbA== MIME-Version: 1.0 Received: by 10.180.92.71 with SMTP id ck7mr5743414wib.2.1335530520736; Fri, 27 Apr 2012 05:42:00 -0700 (PDT) Received: by 10.216.4.73 with HTTP; Fri, 27 Apr 2012 05:42:00 -0700 (PDT) In-Reply-To: <1335529784.312628425@apps.rackspace.com> References: <4F97AF20.5010504@redhat.com> <4F97F8C0.8000606@redhat.com> <1335361289.520918729@apps.rackspace.com> <1335362551.638331582@apps.rackspace.com> <1335364209.259914029@apps.rackspace.com> <4F9A540B.20609@blueyonder.co.uk> <1335529784.312628425@apps.rackspace.com> Date: Fri, 27 Apr 2012 14:42:00 +0200 Message-ID: Subject: Re: Duplating Messages From: Rob Godfrey To: users@qpid.apache.org Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable On 27 April 2012 14:29, wrote: > > Hi Fraser, > > Thaks for the input. =A0I am facing the same issue where client side sele= ctors are not removing messages from the queue even though in the logs it l= ooks all OK: > > match(true) selector(31556811):Id=3D11977 > Dispatcher-Channel-0 2012-04-27 09:21:39,663 DEBUG [apache.qpid.client.Ba= sicMessageConsumer_0_10] messageOk true > . > > main 2012-04-27 09:21:39,669 DEBUG [apache.qpid.client.AMQSession_0_10] S= ending ack for delivery tag 2 on session 0 > main 2012-04-27 09:21:39,669 DEBUG [apache.qpid.transport.Session] ssn:"4= be3c0c9-225a-43be-88d0-fe59a9f2a972" processed([2, 2]) 1 1 > > However, the messages remain. I tried the client_ack mode yesterday to no= avail - same problem. > > A REST interface sounds great - we will need to interface with Qpid from = iOS as well - but we are considering porting the C++ code - hmmm, client si= de selectors aren't implemented yet in the C++ client I believe. =A0This co= uld be a problem. > I'm not overly familiar with the C++ API but I would hope that it should be possible to add arbitrary arguments into the creation of the consumer... in which case you should be able to create the necessary selector and just pass it straight to the Java Broker. -- Rob --------------------------------------------------------------------- To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org For additional commands, e-mail: users-help@qpid.apache.org