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 AD735C14D for ; Fri, 27 Apr 2012 12:32:33 +0000 (UTC) Received: (qmail 10657 invoked by uid 500); 27 Apr 2012 12:32:33 -0000 Delivered-To: apmail-qpid-users-archive@qpid.apache.org Received: (qmail 10625 invoked by uid 500); 27 Apr 2012 12:32:33 -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 10617 invoked by uid 99); 27 Apr 2012 12:32:33 -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:32:33 +0000 X-ASF-Spam-Status: No, hits=2.2 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_NEUTRAL X-Spam-Check-By: apache.org Received-SPF: neutral (nike.apache.org: local policy) Received: from [207.97.245.195] (HELO smtp195.iad.emailsrvr.com) (207.97.245.195) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 27 Apr 2012 12:32:26 +0000 Received: from localhost (localhost.localdomain [127.0.0.1]) by smtp49.relay.iad1a.emailsrvr.com (SMTP Server) with ESMTP id BA4FF1901D3 for ; Fri, 27 Apr 2012 08:31:49 -0400 (EDT) X-Virus-Scanned: OK Received: from legacy24.wa-web.iad1a (legacy24.wa-web.iad1a.rsapps.net [192.168.4.177]) by smtp49.relay.iad1a.emailsrvr.com (SMTP Server) with ESMTP id A61601901D0 for ; Fri, 27 Apr 2012 08:31:49 -0400 (EDT) Received: from smartasking.com (localhost.localdomain [127.0.0.1]) by legacy24.wa-web.iad1a (Postfix) with ESMTP id 7A7C52EF8002 for ; Fri, 27 Apr 2012 08:31:49 -0400 (EDT) Received: by apps.rackspace.com (Authenticated sender: m.luchak@smartasking.com, from: m.luchak@smartasking.com) with HTTP; Fri, 27 Apr 2012 08:31:49 -0400 (EDT) Date: Fri, 27 Apr 2012 08:31:49 -0400 (EDT) Subject: Re: Duplating Messages From: m.luchak@smartasking.com To: users@qpid.apache.org MIME-Version: 1.0 Content-Type: multipart/alternative;boundary="----=_20120427083149000000_32655" Importance: Normal X-Priority: 3 (Normal) X-Type: html In-Reply-To: References: <4F97AF20.5010504@redhat.com> <4F97F8C0.8000606@redhat.com> <1335361289.520918729@apps.rackspace.com> <1335362551.638331582@apps.rackspace.com> <1335464838.57922510@apps.rackspace.com> <1335466756.119227984@apps.rackspace.com> <4F999BBE.9060708@redhat.com> <1335473773.300132232@apps.rackspace.com> <1335475059.882115320@apps.rackspace.com> <1335475923.123619941@apps.rackspace.com> Message-ID: <1335529909.499820830@apps.rackspace.com> X-Mailer: webmail7.0 ------=_20120427083149000000_32655 Content-Type: text/plain; charset="UTF-8" Content-Transfer-Encoding: quoted-printable =0AHi Rob,=0A =0Ahmmm... Still not consuming messages here..=0A =0A=0A Mess= ageConsumer acker=3D (MessageConsumer) session.createConsumer(queue); // c= onsumes all messages on queue=0A MessageConsumer acker =3D (MessageConsume= r) session.createConsumer(queue, "Id=3D11977"); // returns selected message= but does not consume=0A=0A=0AFraser mentioned the same problem. Is there = something that we are missing?=0A =0Athanks,=0AMatthew=0A =0A-----Original = Message-----=0AFrom: "Rob Godfrey" =0ASent: Friday= , April 27, 2012 4:59am=0ATo: users@qpid.apache.org=0ASubject: Re: Duplatin= g Messages=0A=0A=0A=0AOK - I've looked this morning and I am also seeing an= issue with=0Apulling back based on JMSMessageID - but this may be my error= -I've=0Anot looked closely yet.=0A=0AIf I use a selector based on the mess= age property than it behaves as=0Aexpected, and the consumer consumes the m= essage, meaning next time I=0Abrowse there is one less message on the queue= .=0A=0A-- Rob=0A=0AOn 26 April 2012 23:32, wrot= e:=0A>=0A> Eessh... bordering on spam...=0A>=0A> ok... got the selector pul= ling selected messages by:=0A>=0A> producer -> m.setIntProperty("Id", 44444= 4444);=0A>=0A> consumer -> MessageConsumer acker =3D (MessageConsumer) sess= ion.createConsumer(ack,"Id=3D444444444");=0A>=0A> -----Original Message----= -=0A> From: m.luchak@smartasking.com=0A> Sent: Thursday, April 26, 2012 5:1= 7pm=0A> To: users@qpid.apache.org=0A> Subject: Re: Duplating Messages=0A>= =0A>=0A>=0A> Just some more detailed info (tried messageID as this is being= returned by the logs). Any help greatly appreciated..=0A>=0A> LOG:=0A>=0A= > main 2012-04-26 18:13:09,728 DEBUG [apache.qpid.transport.Connection] SEN= D: [conn:10ea9ba] ch=3D0 id=3D9 MessageSubscribe(queue=3Dtest_queue, destin= ation=3D2, acceptMode=3DEXPLICIT, acquireMode=3DNOT_ACQUIRED, resumeTtl=3D0= , arguments=3D{x-filter-jms-selector=3DmessageId=3D8165b87f-8e8e-3e97-991f-= 51b5e45fefab})=0A>=0A>=0A> IoReceiver - localhost/127.0.0.1:5672 2012-04-26= 18:13:09,758 DEBUG [apache.qpid.transport.Session] ID: [0] 4=0A> IoReceive= r - localhost/127.0.0.1:5672 2012-04-26 18:13:09,758 DEBUG [apache.qpid.cli= ent.AMQSession] Message[org.apache.qpid.client.message.UnprocessedMessage_0= _10@b1cd0] received in session=0A> IoReceiver - localhost/127.0.0.1:5672 20= 12-04-26 18:13:09,760 DEBUG [apache.qpid.transport.Connection] RECV: [conn:= 10ea9ba] ch=3D0 MessageTransfer(destination=3D1, acceptMode=3DEXPLICIT, acq= uireMode=3DNOT_ACQUIRED)=0A> MessageProperties(contentLength=3D435, message= Id=3D8165b87f-8e8e-3e97-991f-51b5e45fefab, contentType=3Damqp/map, userId= =3D[B@190a0d6, applicationHeaders=3D{price=3D0.99, name=3DWidget, Id=3D4444= 44444})=0A> DeliveryProperties(priority=3DMEDIUM, deliveryMode=3DPERSISTENT= , timestamp=3D1335469525112, exchange=3D, routingKey=3Dtest_queue)=0A>=0A>= =0A> -----Original Message-----=0A> From: m.luchak@smartasking.com=0A> Sent= : Thursday, April 26, 2012 4:56pm=0A> To: users@qpid.apache.org=0A> Subject= : Re: Duplating Messages=0A>=0A>=0A>=0A> hey.. me again ;)=0A>=0A> not sure= if I'm doing this right... creating a consumer with JMSMessageID as a sele= ctor but it's not returning the message even though this message does exist= (checked 5 times ;).=0A>=0A> code:=0A> MessageConsumer acker =3D (MessageC= onsumer) session.createConsumer(ack,"JMSMessageID=3D8165b87f-8e8e-3e97-991f= -51b5e45fefab");=0A>=0A> MapMessage m =3D (MapMessage)acker.receive();=0A>= =0A> LOG:=0A> main 2012-04-26 17:51:23,901 DEBUG [apache.qpid.filter.JMSSel= ectorFilter] Created JMSSelectorFilter with selector:JMSMessageID=3D8165b87= f-8e8e-3e97-991f-51b5e45fefab=0A>=0A> -----Original Message-----=0A> From: = "Gordon Sim" =0A> Sent: Thursday, April 26, 2012 3:02pm=0A= > To: users@qpid.apache.org=0A> Subject: Re: Duplating Messages=0A>=0A>=0A>= =0A> On 04/26/2012 07:59 PM, m.luchak@smartasking.com wrote:=0A>> going for= the straight forward approach of creating a new connection to select and a= ck the message using ... JMSMessageID I guess?... will try it out...=0A>=0A= > This has the advantage of being easily transferable to 1.0 if/when needed= .=0A>=0A> -----------------------------------------------------------------= ----=0A> To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org=0A> For = additional commands, e-mail: users-help@qpid.apache.org=0A>=0A=0A----------= -----------------------------------------------------------=0ATo unsubscrib= e, e-mail: users-unsubscribe@qpid.apache.org=0AFor additional commands, e-m= ail: users-help@qpid.apache.org=0A=0A ------=_20120427083149000000_32655--