Return-Path: Delivered-To: apmail-camel-users-archive@www.apache.org Received: (qmail 37073 invoked from network); 9 Mar 2010 17:52:26 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 9 Mar 2010 17:52:26 -0000 Received: (qmail 37362 invoked by uid 500); 9 Mar 2010 17:51:58 -0000 Delivered-To: apmail-camel-users-archive@camel.apache.org Received: (qmail 37332 invoked by uid 500); 9 Mar 2010 17:51:58 -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 37324 invoked by uid 99); 9 Mar 2010 17:51:58 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 09 Mar 2010 17:51:58 +0000 X-ASF-Spam-Status: No, hits=0.0 required=10.0 tests=FREEMAIL_FROM,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of norman.maurer@googlemail.com designates 74.125.82.45 as permitted sender) Received: from [74.125.82.45] (HELO mail-ww0-f45.google.com) (74.125.82.45) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 09 Mar 2010 17:51:57 +0000 Received: by wwb34 with SMTP id 34so3896533wwb.32 for ; Tue, 09 Mar 2010 09:51:36 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=googlemail.com; s=gamma; h=domainkey-signature:mime-version:received:in-reply-to:references :date:message-id:subject:from:to:content-type :content-transfer-encoding; bh=7CkmU6vTJ/X0dKj1sAcVL5xq9U73oHx4Rj7DCdXtsmc=; b=R3WoK6eWWsJ9aH8Ug1CnIzF5JLdzrUA97BBjUQBfpk48EM5awcHWQ2POgwP7jR+Nfg xqtQn7qkei5FP2NT2xUMzoL+VBHKYZM3Ns0TMIh5yrT3zDm+x7pS9K+5OEdOKBAsFlhP 813JhoKcEjs/+bngqUl48g8aILG1LYg+5Pu6U= DomainKey-Signature: a=rsa-sha1; c=nofws; d=googlemail.com; s=gamma; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type:content-transfer-encoding; b=Y68CpezLWjrlXJ4/3uAnBrlGoLszrsrwlHQKAYc8ZMY/Bg+uFsgZ3tYO02ukid+vg8 /o9QK4ehaJrXC/mlX8f3RrtLA9HG+0TBBbjb9p/I/KYuWHbS2AZZdwGU/mpPMj4w5Yz1 MwgAdlmG5be6nYPZAO5b5G/AVQdoeQhA1GRR0= MIME-Version: 1.0 Received: by 10.216.93.77 with SMTP id k55mr68571wef.196.1268157096070; Tue, 09 Mar 2010 09:51:36 -0800 (PST) In-Reply-To: <4B94CEF8.6080402@gmail.com> 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> Date: Tue, 9 Mar 2010 18:51:36 +0100 Message-ID: <75bda7a01003090951r5e81e334md0e4058427d8e556@mail.gmail.com> Subject: Re: activemq component and selector From: Norman Maurer To: users@camel.apache.org Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable 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, > > =A0I can reproduce you issue by use the ConsumerTemplate to get the messa= ge, > 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/ja= va/org/apache/james/transport/camel/ActiveMQPollingConsumer.java?view=3Dmar= kup >> >> 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=3D920216&view=3Drev >>> >>> Willem >>> Norman Maurer wrote: >>>> >>>> Hi Willem, >>>> >>>> its listed in the jms component site (the one you linked)... >>>> >>>> Most commonly used options: >>>> selector =A0 =A0 =A0 =A0 null =A0 =A0Sets the JMS Selector, which is a= n SQL 92 >>>> predicate >>>> that is used to filter messages within the broker. You may have to >>>> encode special characters such as =3D 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 messa= ge >>>>>> does not match the selector I used this as uri: >>>>>> >>>>>> >>>>>> >>>>>> consumerTemplate.receiveNoWait("activemq:queue:myqueue?selector=3DNE= XT_RETRY >>>>>> < " + System.currentTimeMillis()); >>>>>> >>>>>> Any idea ? >>>>>> >>>>>> Bye, >>>>>> Norman >>>>>> >>> >> > >