camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Norman Maurer <norman.mau...@googlemail.com>
Subject Re: activemq component and selector
Date Tue, 09 Mar 2010 17:51:36 GMT
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 <willem.jiang@gmail.com>:
> 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 <willem.jiang@gmail.com>:
>>>
>>> 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 <willem.jiang@gmail.com>:
>>>>>
>>>>> 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
>>>>>>
>>>
>>
>
>

Mime
View raw message