Return-Path: Delivered-To: apmail-camel-users-archive@www.apache.org Received: (qmail 65902 invoked from network); 10 Mar 2010 00:45:05 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 10 Mar 2010 00:45:05 -0000 Received: (qmail 88313 invoked by uid 500); 10 Mar 2010 00:44:36 -0000 Delivered-To: apmail-camel-users-archive@camel.apache.org Received: (qmail 88270 invoked by uid 500); 10 Mar 2010 00:44:36 -0000 Mailing-List: contact users-help@camel.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@camel.apache.org Delivered-To: mailing list users@camel.apache.org Received: (qmail 88262 invoked by uid 99); 10 Mar 2010 00:44:36 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 10 Mar 2010 00:44:36 +0000 X-ASF-Spam-Status: No, hits=0.0 required=10.0 tests=FREEMAIL_FROM,RCVD_IN_DNSWL_NONE,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of willem.jiang@gmail.com designates 209.85.221.175 as permitted sender) Received: from [209.85.221.175] (HELO mail-qy0-f175.google.com) (209.85.221.175) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 10 Mar 2010 00:44:27 +0000 Received: by qyk5 with SMTP id 5so2205016qyk.13 for ; Tue, 09 Mar 2010 16:44:06 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:received:received:message-id:date:from :user-agent:mime-version:to:subject:references:in-reply-to :content-type:content-transfer-encoding; bh=O6P997+GQZ7vUI6hGSeYpR+o6l8JZzOASx5DHfdI2Og=; b=DnG0kNXO7QZrzIGt9j8GcuZf14gR470w+DEVvQAJxNnros52C5zvgRSNsI4qt5VPZJ GFgp1dF63sBGPrbzFoStCVFgIFL2yguESrxHVS1an+tAECQ/tCoQzXJaG2q0juUD+IlT +Fdp3qsCq+o+wW8a9m8zLJo9x6v1/GDAEs3uQ= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=message-id:date:from:user-agent:mime-version:to:subject:references :in-reply-to:content-type:content-transfer-encoding; b=xPeoGwAcGCtUiQpmZfJw3QHNOqCs+g4DC1S/9wcrXANMR/5u+lfO3Np6rXA1q7uKfE R4AHUW0/XagqCPXupLHhSz7r9a5Xgh2lSBnk5NrKOeB66fxIiiXm3sUvh68X0uDiokGV cNqDyAFmFeWWkNVRdONpg7Aj1tEGloV8hOBU8= Received: by 10.224.45.1 with SMTP id c1mr560545qaf.87.1268181846780; Tue, 09 Mar 2010 16:44:06 -0800 (PST) Received: from [192.168.0.158] ([125.34.6.1]) by mx.google.com with ESMTPS id 8sm15886717qwj.25.2010.03.09.16.44.03 (version=TLSv1/SSLv3 cipher=RC4-MD5); Tue, 09 Mar 2010 16:44:05 -0800 (PST) Message-ID: <4B96EB50.4020304@gmail.com> Date: Wed, 10 Mar 2010 08:44:00 +0800 From: Willem Jiang User-Agent: Thunderbird 2.0.0.23 (Macintosh/20090812) MIME-Version: 1.0 To: users@camel.apache.org Subject: Re: activemq component and selector References: <75bda7a01003071112x6cca3140s5c92b3178cbfe3db@mail.gmail.com> <4B947108.40408@gmail.com> <75bda7a01003072133h36e43a3fs37c490d230368ef0@mail.gmail.com> <4B94A60B.3030005@gmail.com> <75bda7a01003072343k635aa135xda415346d76aaf66@mail.gmail.com> <4B94CEF8.6080402@gmail.com> <75bda7a01003090951r5e81e334md0e4058427d8e556@mail.gmail.com> In-Reply-To: <75bda7a01003090951r5e81e334md0e4058427d8e556@mail.gmail.com> Content-Type: text/plain; charset=ISO-8859-1; format=flowed Content-Transfer-Encoding: 7bit X-Virus-Checked: Checked by ClamAV on apache.org Cool, it's good to see it work. Please keep on exploring camel-jms component, and feel free to send us feed back. Willem Norman Maurer wrote: > Hi Willem, > > I just updated to 2.3-SNAPSHOT and the selector now seems to work as > aspected. Good work :) > > Bye, > Norman > > 2010/3/8 Willem Jiang : >> Hi Norman, >> >> I can reproduce you issue by use the ConsumerTemplate to get the message, >> and I filled a JIRA[1] for it. >> >> [1]https://issues.apache.org/activemq/browse/CAMEL-2529 >> >> Willem >> >> Norman Maurer wrote: >>> Hi William, >>> >>> will try the test later today when I have the code around. At the >>> moment I wonder if its possible something related to use the >>> ConsumerTemplate. I created a Consumer which use the ConsumerTemplate >>> to check for messages on a queue and checks for a header value against >>> the current time. You can see the source here: >>> >>> >>> >>> http://svn.apache.org/viewvc/james/server/trunk/spoolmanager/src/main/java/org/apache/james/transport/camel/ActiveMQPollingConsumer.java?view=markup >>> >>> Does this looks ok to you ? >>> >>> Bye, >>> Norman >>> >>> >>> 2010/3/8 Willem Jiang : >>>> Hi Norman, >>>> >>>> It's my mistake, and I just committed a unit test[1] to verify the >>>> selector >>>> option, everything looks good, can you try the test on your environment? >>>> >>>> [1]http://svn.apache.org/viewvc?rev=920216&view=rev >>>> >>>> Willem >>>> Norman Maurer wrote: >>>>> Hi Willem, >>>>> >>>>> its listed in the jms component site (the one you linked)... >>>>> >>>>> Most commonly used options: >>>>> selector null Sets the JMS Selector, which is an SQL 92 >>>>> predicate >>>>> that is used to filter messages within the broker. You may have to >>>>> encode special characters such as = as %3D >>>>> >>>>> Bye, >>>>> Norman >>>>> >>>>> >>>>> 2010/3/8 Willem Jiang : >>>>>> Hi, >>>>>> >>>>>> It's look like camel-activemq[1] or camel-jms[2] don't support to >>>>>> specify >>>>>> the selector option in the URI. >>>>>> >>>>>> [1]http://camel.apache.org/activemq.html >>>>>> [2]http://camel.apache.org/jms.html >>>>>> >>>>>> Willem >>>>>> >>>>>> Norman Maurer wrote: >>>>>>> Hi all, >>>>>>> >>>>>>> today I tried to use the message selector with activemq camel >>>>>>> component. But It seems to just return the message even if the message >>>>>>> does not match the selector I used this as uri: >>>>>>> >>>>>>> >>>>>>> >>>>>>> consumerTemplate.receiveNoWait("activemq:queue:myqueue?selector=NEXT_RETRY >>>>>>> < " + System.currentTimeMillis()); >>>>>>> >>>>>>> Any idea ? >>>>>>> >>>>>>> Bye, >>>>>>> Norman >>>>>>> >> >