You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by cmoulliard <cm...@gmail.com> on 2008/11/03 17:09:42 UTC
Can Camel read an uri like this "activemq:topic:stock.*" ?
Hi,
I would like to know if Camel can read an uri like this (from
uri="activemq:topic:stock.*") where the star represents any topic created
with the root name STOCK. ?
KR,
Charles
-----
Enterprise Architect
Xpectis
12, route d'Esch
L-1470 Luxembourg
Phone +352 25 10 70 470
Mobile +352 621 45 36 22
e-mail : cmoulliard@xpectis.com
web site : www.xpectis.com www.xpectis.com
My Blog : http://cmoulliard.blogspot.com/ http://cmoulliard.blogspot.com/
--
View this message in context: http://www.nabble.com/Can-Camel-read-an-uri-like-this-%22activemq%3Atopic%3Astock.*%22----tp20305361s22882p20305361.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Can Camel read an uri like this "activemq:topic:stock.*" ?
Posted by James Strachan <ja...@gmail.com>.
Have you tried using a simple client sender and consumer first to
check wildards work? (e.g. test the endpoints first in a little JUnit
test case without using a recipient List).
Can you submit a JUnit test case showing wildcard topics not working?
2008/11/5 cmoulliard <cm...@gmail.com>:
>
> Does anybody has an idea ?
>
>
> cmoulliard wrote:
>>
>> Like mentioned before the first part of the route works. So, messages are
>> published in STOCK.ING, STOCK.COLR, STOCK.* ... and are readable through
>> jmx console
>>
>>
>>
>> James.Strachan wrote:
>>>
>>> If you send a message to a jms:topic.STOCK.FOO does it work?
>>>
>>> Does your {$in.header.stock} contain any dots?
>>>
>>>
>>> 2008/11/3 cmoulliard <cm...@gmail.com>:
>>>>
>>>> Unfortunately, removing the // does not help :
>>>>
>>>> <recipientList>
>>>>
>>>> <simple>jms:topic:STOCK.${in.header.stock}</simple>
>>>> </recipientList>
>>>> </splitter>
>>>> </route>
>>>> <route>
>>>> <from uri="jms:topic:STOCK.*" />
>>>>
>>>>
>>>> James.Strachan wrote:
>>>>>
>>>>> Try use the URI you said - jms:topic.STOCK.* rather than
>>>>> jms:topic.//STOCK.*
>>>>>
>>>>> 2008/11/3 cmoulliard <cm...@gmail.com>:
>>>>>>
>>>>>> This is strange because the following routing does not work
>>>>>>
>>>>>> <?xml version="1.0" encoding="UTF-8"?>
>>>>>> <beans xmlns="http://www.springframework.org/schema/beans"
>>>>>> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
>>>>>> xmlns:context="http://www.springframework.org/schema/context"
>>>>>> xsi:schemaLocation="
>>>>>> http://www.springframework.org/schema/beans
>>>>>> http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
>>>>>> http://www.springframework.org/schema/context
>>>>>>
>>>>>> http://www.springframework.org/schema/context/spring-context-2.5.xsd
>>>>>> http://activemq.apache.org/camel/schema/spring
>>>>>>
>>>>>> http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">
>>>>>>
>>>>>> <!-- ActiveMQ brokerURL using VM protocol -->
>>>>>> <bean id="jms"
>>>>>> class="org.apache.activemq.camel.component.ActiveMQComponent">
>>>>>> <property name="brokerURL"
>>>>>>
>>>>>> value="vm://localhost:61616?broker.persistent=true" />
>>>>>> </bean>
>>>>>>
>>>>>> <!-- This config does not work
>>>>>> <bean id="jms"
>>>>>> class="org.apache.camel.component.jms.JmsComponent">
>>>>>> <property name="connectionFactory">
>>>>>> <bean
>>>>>> class="org.apache.activemq.ActiveMQConnectionFactory">
>>>>>> <property name="brokerURL"
>>>>>> value="vm://localhost:61616?broker.persistent=false" />
>>>>>> </bean>
>>>>>> </property>
>>>>>> </bean>
>>>>>> -->
>>>>>>
>>>>>> <bean id="camelTracer"
>>>>>> class="org.apache.camel.processor.interceptor.Tracer">
>>>>>> <property name="traceExceptions" value="false" />
>>>>>> <property name="traceInterceptors" value="true" />
>>>>>> <property name="logLevel" value="DEBUG" />
>>>>>> <property name="logName" value="com.xpectis.tracker" />
>>>>>> </bean>
>>>>>>
>>>>>> <bean id="traceFormatter"
>>>>>> class="org.apache.camel.processor.interceptor.TraceFormatter">
>>>>>> <property name="showBody" value="true" />
>>>>>> <property name="showHeaders" value="true" />
>>>>>> <property name="showBodyType" value="false" />
>>>>>> <property name="showBreadCrumb" value="false" />
>>>>>> </bean>
>>>>>>
>>>>>> <!-- Based on Formatter class but no more required since 1.5
>>>>>> <bean id="myXstreamDataFormat"
>>>>>> class="com.xpectis.model.Formatter"
>>>>>> factory-method="createInstance">
>>>>>> <constructor-arg value="com.xpectis.model.StockPrice"
>>>>>> />
>>>>>> </bean>
>>>>>> -->
>>>>>> <bean id="myXstreamDataFormat"
>>>>>> class="org.apache.camel.dataformat.xstream.XStreamDataFormat"
>>>>>> factory-method="processAnnotations">
>>>>>> <constructor-arg value="com.xpectis.model.StockPrice"
>>>>>> />
>>>>>> </bean>
>>>>>>
>>>>>> <bean id="stockPriceGenerator"
>>>>>> class="com.xpectis.service.common.impl.StockPriceGenerator" />
>>>>>> <bean id="stockUpdater"
>>>>>> class="com.xpectis.service.common.impl.StockUpdater" />
>>>>>>
>>>>>> <camelContext id="camel" trace="true"
>>>>>> xmlns="http://activemq.apache.org/camel/schema/spring">
>>>>>> <!-- <jmxAgent id="agent" createConnector="true" />
>>>>>> -->
>>>>>> <route>
>>>>>> <from
>>>>>> uri="timer:generateStockPrice?fixedRate=true&delay=10000&period=5000"
>>>>>> />
>>>>>> <to uri="bean:stockPriceGenerator" />
>>>>>> <marshal ref="myXstreamDataFormat" />
>>>>>> <splitter>
>>>>>> <xpath>//price</xpath>
>>>>>> <setHeader headerName="stock">
>>>>>> <xpath>//price/@stock</xpath>
>>>>>> </setHeader>
>>>>>> <recipientList>
>>>>>>
>>>>>> <simple>jms:topic://STOCK.${in.header.stock}</simple>
>>>>>> </recipientList>
>>>>>> </splitter>
>>>>>> </route>
>>>>>> <!-- everything works fine till here -->
>>>>>>
>>>>>> <route>
>>>>>> <from uri="jms:topic://STOCK.*" />
>>>>>> <unmarshal ref="myXstreamDataFormat" />
>>>>>> <to uri="bean:stockUpdater" />
>>>>>> <!-- nothing arrives at my bean -->
>>>>>> </route>
>>>>>>
>>>>>> </camelContext>
>>>>>>
>>>>>> </beans>
>>>>>>
>>>>>>
>>>>>>
>>>>>> James.Strachan wrote:
>>>>>>>
>>>>>>> 2008/11/3 cmoulliard <cm...@gmail.com>:
>>>>>>>>
>>>>>>>> Hi,
>>>>>>>>
>>>>>>>> I would like to know if Camel can read an uri like this (from
>>>>>>>> uri="activemq:topic:stock.*") where the star represents any topic
>>>>>>>> created
>>>>>>>> with the root name STOCK. ?
>>>>>>>
>>>>>>> Yes
>>>>>>>
>>>>>>> --
>>>>>>> James
>>>>>>> -------
>>>>>>> http://macstrac.blogspot.com/
>>>>>>>
>>>>>>> Open Source Integration
>>>>>>> http://fusesource.com/
>>>>>>>
>>>>>>>
>>>>>>
>>>>>>
>>>>>> -----
>>>>>> Enterprise Architect
>>>>>>
>>>>>> Xpectis
>>>>>> 12, route d'Esch
>>>>>> L-1470 Luxembourg
>>>>>>
>>>>>> Phone +352 25 10 70 470
>>>>>> Mobile +352 621 45 36 22
>>>>>>
>>>>>> e-mail : cmoulliard@xpectis.com
>>>>>> web site : www.xpectis.com www.xpectis.com
>>>>>> My Blog : http://cmoulliard.blogspot.com/
>>>>>> http://cmoulliard.blogspot.com/
>>>>>> --
>>>>>> View this message in context:
>>>>>> http://www.nabble.com/Can-Camel-read-an-uri-like-this-%22activemq%3Atopic%3Astock.*%22----tp20305361s22882p20305700.html
>>>>>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>>>>>
>>>>>>
>>>>>
>>>>>
>>>>>
>>>>> --
>>>>> James
>>>>> -------
>>>>> http://macstrac.blogspot.com/
>>>>>
>>>>> Open Source Integration
>>>>> http://fusesource.com/
>>>>>
>>>>>
>>>>
>>>>
>>>> -----
>>>> Enterprise Architect
>>>>
>>>> Xpectis
>>>> 12, route d'Esch
>>>> L-1470 Luxembourg
>>>>
>>>> Phone +352 25 10 70 470
>>>> Mobile +352 621 45 36 22
>>>>
>>>> e-mail : cmoulliard@xpectis.com
>>>> web site : www.xpectis.com www.xpectis.com
>>>> My Blog : http://cmoulliard.blogspot.com/
>>>> http://cmoulliard.blogspot.com/
>>>> --
>>>> View this message in context:
>>>> http://www.nabble.com/Can-Camel-read-an-uri-like-this-%22activemq%3Atopic%3Astock.*%22----tp20305361s22882p20305976.html
>>>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>>>
>>>>
>>>
>>>
>>>
>>> --
>>> James
>>> -------
>>> http://macstrac.blogspot.com/
>>>
>>> Open Source Integration
>>> http://fusesource.com/
>>>
>>>
>>
>>
>
>
> -----
> Enterprise Architect
>
> Xpectis
> 12, route d'Esch
> L-1470 Luxembourg
>
> Phone +352 25 10 70 470
> Mobile +352 621 45 36 22
>
> e-mail : cmoulliard@xpectis.com
> web site : www.xpectis.com www.xpectis.com
> My Blog : http://cmoulliard.blogspot.com/ http://cmoulliard.blogspot.com/
> --
> View this message in context: http://www.nabble.com/Can-Camel-read-an-uri-like-this-%22activemq%3Atopic%3Astock.*%22----tp20305361s22882p20337752.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
>
--
James
-------
http://macstrac.blogspot.com/
Open Source Integration
http://fusesource.com/
Re: Can Camel read an uri like this "activemq:topic:stock.*" ?
Posted by cmoulliard <cm...@gmail.com>.
Does anybody has an idea ?
cmoulliard wrote:
>
> Like mentioned before the first part of the route works. So, messages are
> published in STOCK.ING, STOCK.COLR, STOCK.* ... and are readable through
> jmx console
>
>
>
> James.Strachan wrote:
>>
>> If you send a message to a jms:topic.STOCK.FOO does it work?
>>
>> Does your {$in.header.stock} contain any dots?
>>
>>
>> 2008/11/3 cmoulliard <cm...@gmail.com>:
>>>
>>> Unfortunately, removing the // does not help :
>>>
>>> <recipientList>
>>>
>>> <simple>jms:topic:STOCK.${in.header.stock}</simple>
>>> </recipientList>
>>> </splitter>
>>> </route>
>>> <route>
>>> <from uri="jms:topic:STOCK.*" />
>>>
>>>
>>> James.Strachan wrote:
>>>>
>>>> Try use the URI you said - jms:topic.STOCK.* rather than
>>>> jms:topic.//STOCK.*
>>>>
>>>> 2008/11/3 cmoulliard <cm...@gmail.com>:
>>>>>
>>>>> This is strange because the following routing does not work
>>>>>
>>>>> <?xml version="1.0" encoding="UTF-8"?>
>>>>> <beans xmlns="http://www.springframework.org/schema/beans"
>>>>> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
>>>>> xmlns:context="http://www.springframework.org/schema/context"
>>>>> xsi:schemaLocation="
>>>>> http://www.springframework.org/schema/beans
>>>>> http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
>>>>> http://www.springframework.org/schema/context
>>>>>
>>>>> http://www.springframework.org/schema/context/spring-context-2.5.xsd
>>>>> http://activemq.apache.org/camel/schema/spring
>>>>>
>>>>> http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">
>>>>>
>>>>> <!-- ActiveMQ brokerURL using VM protocol -->
>>>>> <bean id="jms"
>>>>> class="org.apache.activemq.camel.component.ActiveMQComponent">
>>>>> <property name="brokerURL"
>>>>>
>>>>> value="vm://localhost:61616?broker.persistent=true" />
>>>>> </bean>
>>>>>
>>>>> <!-- This config does not work
>>>>> <bean id="jms"
>>>>> class="org.apache.camel.component.jms.JmsComponent">
>>>>> <property name="connectionFactory">
>>>>> <bean
>>>>> class="org.apache.activemq.ActiveMQConnectionFactory">
>>>>> <property name="brokerURL"
>>>>> value="vm://localhost:61616?broker.persistent=false" />
>>>>> </bean>
>>>>> </property>
>>>>> </bean>
>>>>> -->
>>>>>
>>>>> <bean id="camelTracer"
>>>>> class="org.apache.camel.processor.interceptor.Tracer">
>>>>> <property name="traceExceptions" value="false" />
>>>>> <property name="traceInterceptors" value="true" />
>>>>> <property name="logLevel" value="DEBUG" />
>>>>> <property name="logName" value="com.xpectis.tracker" />
>>>>> </bean>
>>>>>
>>>>> <bean id="traceFormatter"
>>>>> class="org.apache.camel.processor.interceptor.TraceFormatter">
>>>>> <property name="showBody" value="true" />
>>>>> <property name="showHeaders" value="true" />
>>>>> <property name="showBodyType" value="false" />
>>>>> <property name="showBreadCrumb" value="false" />
>>>>> </bean>
>>>>>
>>>>> <!-- Based on Formatter class but no more required since 1.5
>>>>> <bean id="myXstreamDataFormat"
>>>>> class="com.xpectis.model.Formatter"
>>>>> factory-method="createInstance">
>>>>> <constructor-arg value="com.xpectis.model.StockPrice"
>>>>> />
>>>>> </bean>
>>>>> -->
>>>>> <bean id="myXstreamDataFormat"
>>>>> class="org.apache.camel.dataformat.xstream.XStreamDataFormat"
>>>>> factory-method="processAnnotations">
>>>>> <constructor-arg value="com.xpectis.model.StockPrice"
>>>>> />
>>>>> </bean>
>>>>>
>>>>> <bean id="stockPriceGenerator"
>>>>> class="com.xpectis.service.common.impl.StockPriceGenerator" />
>>>>> <bean id="stockUpdater"
>>>>> class="com.xpectis.service.common.impl.StockUpdater" />
>>>>>
>>>>> <camelContext id="camel" trace="true"
>>>>> xmlns="http://activemq.apache.org/camel/schema/spring">
>>>>> <!-- <jmxAgent id="agent" createConnector="true" />
>>>>> -->
>>>>> <route>
>>>>> <from
>>>>> uri="timer:generateStockPrice?fixedRate=true&delay=10000&period=5000"
>>>>> />
>>>>> <to uri="bean:stockPriceGenerator" />
>>>>> <marshal ref="myXstreamDataFormat" />
>>>>> <splitter>
>>>>> <xpath>//price</xpath>
>>>>> <setHeader headerName="stock">
>>>>> <xpath>//price/@stock</xpath>
>>>>> </setHeader>
>>>>> <recipientList>
>>>>>
>>>>> <simple>jms:topic://STOCK.${in.header.stock}</simple>
>>>>> </recipientList>
>>>>> </splitter>
>>>>> </route>
>>>>> <!-- everything works fine till here -->
>>>>>
>>>>> <route>
>>>>> <from uri="jms:topic://STOCK.*" />
>>>>> <unmarshal ref="myXstreamDataFormat" />
>>>>> <to uri="bean:stockUpdater" />
>>>>> <!-- nothing arrives at my bean -->
>>>>> </route>
>>>>>
>>>>> </camelContext>
>>>>>
>>>>> </beans>
>>>>>
>>>>>
>>>>>
>>>>> James.Strachan wrote:
>>>>>>
>>>>>> 2008/11/3 cmoulliard <cm...@gmail.com>:
>>>>>>>
>>>>>>> Hi,
>>>>>>>
>>>>>>> I would like to know if Camel can read an uri like this (from
>>>>>>> uri="activemq:topic:stock.*") where the star represents any topic
>>>>>>> created
>>>>>>> with the root name STOCK. ?
>>>>>>
>>>>>> Yes
>>>>>>
>>>>>> --
>>>>>> James
>>>>>> -------
>>>>>> http://macstrac.blogspot.com/
>>>>>>
>>>>>> Open Source Integration
>>>>>> http://fusesource.com/
>>>>>>
>>>>>>
>>>>>
>>>>>
>>>>> -----
>>>>> Enterprise Architect
>>>>>
>>>>> Xpectis
>>>>> 12, route d'Esch
>>>>> L-1470 Luxembourg
>>>>>
>>>>> Phone +352 25 10 70 470
>>>>> Mobile +352 621 45 36 22
>>>>>
>>>>> e-mail : cmoulliard@xpectis.com
>>>>> web site : www.xpectis.com www.xpectis.com
>>>>> My Blog : http://cmoulliard.blogspot.com/
>>>>> http://cmoulliard.blogspot.com/
>>>>> --
>>>>> View this message in context:
>>>>> http://www.nabble.com/Can-Camel-read-an-uri-like-this-%22activemq%3Atopic%3Astock.*%22----tp20305361s22882p20305700.html
>>>>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>>>>
>>>>>
>>>>
>>>>
>>>>
>>>> --
>>>> James
>>>> -------
>>>> http://macstrac.blogspot.com/
>>>>
>>>> Open Source Integration
>>>> http://fusesource.com/
>>>>
>>>>
>>>
>>>
>>> -----
>>> Enterprise Architect
>>>
>>> Xpectis
>>> 12, route d'Esch
>>> L-1470 Luxembourg
>>>
>>> Phone +352 25 10 70 470
>>> Mobile +352 621 45 36 22
>>>
>>> e-mail : cmoulliard@xpectis.com
>>> web site : www.xpectis.com www.xpectis.com
>>> My Blog : http://cmoulliard.blogspot.com/
>>> http://cmoulliard.blogspot.com/
>>> --
>>> View this message in context:
>>> http://www.nabble.com/Can-Camel-read-an-uri-like-this-%22activemq%3Atopic%3Astock.*%22----tp20305361s22882p20305976.html
>>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>>
>>>
>>
>>
>>
>> --
>> James
>> -------
>> http://macstrac.blogspot.com/
>>
>> Open Source Integration
>> http://fusesource.com/
>>
>>
>
>
-----
Enterprise Architect
Xpectis
12, route d'Esch
L-1470 Luxembourg
Phone +352 25 10 70 470
Mobile +352 621 45 36 22
e-mail : cmoulliard@xpectis.com
web site : www.xpectis.com www.xpectis.com
My Blog : http://cmoulliard.blogspot.com/ http://cmoulliard.blogspot.com/
--
View this message in context: http://www.nabble.com/Can-Camel-read-an-uri-like-this-%22activemq%3Atopic%3Astock.*%22----tp20305361s22882p20337752.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Can Camel read an uri like this "activemq:topic:stock.*" ?
Posted by cmoulliard <cm...@gmail.com>.
Like mentioned before the first part of the route works. So, messages are
published in STOCK.ING, STOCK.COLR, STOCK.* ... and are readable through jmx
console
James.Strachan wrote:
>
> If you send a message to a jms:topic.STOCK.FOO does it work?
>
> Does your {$in.header.stock} contain any dots?
>
>
> 2008/11/3 cmoulliard <cm...@gmail.com>:
>>
>> Unfortunately, removing the // does not help :
>>
>> <recipientList>
>>
>> <simple>jms:topic:STOCK.${in.header.stock}</simple>
>> </recipientList>
>> </splitter>
>> </route>
>> <route>
>> <from uri="jms:topic:STOCK.*" />
>>
>>
>> James.Strachan wrote:
>>>
>>> Try use the URI you said - jms:topic.STOCK.* rather than
>>> jms:topic.//STOCK.*
>>>
>>> 2008/11/3 cmoulliard <cm...@gmail.com>:
>>>>
>>>> This is strange because the following routing does not work
>>>>
>>>> <?xml version="1.0" encoding="UTF-8"?>
>>>> <beans xmlns="http://www.springframework.org/schema/beans"
>>>> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
>>>> xmlns:context="http://www.springframework.org/schema/context"
>>>> xsi:schemaLocation="
>>>> http://www.springframework.org/schema/beans
>>>> http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
>>>> http://www.springframework.org/schema/context
>>>>
>>>> http://www.springframework.org/schema/context/spring-context-2.5.xsd
>>>> http://activemq.apache.org/camel/schema/spring
>>>> http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">
>>>>
>>>> <!-- ActiveMQ brokerURL using VM protocol -->
>>>> <bean id="jms"
>>>> class="org.apache.activemq.camel.component.ActiveMQComponent">
>>>> <property name="brokerURL"
>>>>
>>>> value="vm://localhost:61616?broker.persistent=true" />
>>>> </bean>
>>>>
>>>> <!-- This config does not work
>>>> <bean id="jms"
>>>> class="org.apache.camel.component.jms.JmsComponent">
>>>> <property name="connectionFactory">
>>>> <bean
>>>> class="org.apache.activemq.ActiveMQConnectionFactory">
>>>> <property name="brokerURL"
>>>> value="vm://localhost:61616?broker.persistent=false" />
>>>> </bean>
>>>> </property>
>>>> </bean>
>>>> -->
>>>>
>>>> <bean id="camelTracer"
>>>> class="org.apache.camel.processor.interceptor.Tracer">
>>>> <property name="traceExceptions" value="false" />
>>>> <property name="traceInterceptors" value="true" />
>>>> <property name="logLevel" value="DEBUG" />
>>>> <property name="logName" value="com.xpectis.tracker" />
>>>> </bean>
>>>>
>>>> <bean id="traceFormatter"
>>>> class="org.apache.camel.processor.interceptor.TraceFormatter">
>>>> <property name="showBody" value="true" />
>>>> <property name="showHeaders" value="true" />
>>>> <property name="showBodyType" value="false" />
>>>> <property name="showBreadCrumb" value="false" />
>>>> </bean>
>>>>
>>>> <!-- Based on Formatter class but no more required since 1.5
>>>> <bean id="myXstreamDataFormat"
>>>> class="com.xpectis.model.Formatter"
>>>> factory-method="createInstance">
>>>> <constructor-arg value="com.xpectis.model.StockPrice" />
>>>> </bean>
>>>> -->
>>>> <bean id="myXstreamDataFormat"
>>>> class="org.apache.camel.dataformat.xstream.XStreamDataFormat"
>>>> factory-method="processAnnotations">
>>>> <constructor-arg value="com.xpectis.model.StockPrice" />
>>>> </bean>
>>>>
>>>> <bean id="stockPriceGenerator"
>>>> class="com.xpectis.service.common.impl.StockPriceGenerator" />
>>>> <bean id="stockUpdater"
>>>> class="com.xpectis.service.common.impl.StockUpdater" />
>>>>
>>>> <camelContext id="camel" trace="true"
>>>> xmlns="http://activemq.apache.org/camel/schema/spring">
>>>> <!-- <jmxAgent id="agent" createConnector="true" /> -->
>>>> <route>
>>>> <from
>>>> uri="timer:generateStockPrice?fixedRate=true&delay=10000&period=5000"
>>>> />
>>>> <to uri="bean:stockPriceGenerator" />
>>>> <marshal ref="myXstreamDataFormat" />
>>>> <splitter>
>>>> <xpath>//price</xpath>
>>>> <setHeader headerName="stock">
>>>> <xpath>//price/@stock</xpath>
>>>> </setHeader>
>>>> <recipientList>
>>>>
>>>> <simple>jms:topic://STOCK.${in.header.stock}</simple>
>>>> </recipientList>
>>>> </splitter>
>>>> </route>
>>>> <!-- everything works fine till here -->
>>>>
>>>> <route>
>>>> <from uri="jms:topic://STOCK.*" />
>>>> <unmarshal ref="myXstreamDataFormat" />
>>>> <to uri="bean:stockUpdater" />
>>>> <!-- nothing arrives at my bean -->
>>>> </route>
>>>>
>>>> </camelContext>
>>>>
>>>> </beans>
>>>>
>>>>
>>>>
>>>> James.Strachan wrote:
>>>>>
>>>>> 2008/11/3 cmoulliard <cm...@gmail.com>:
>>>>>>
>>>>>> Hi,
>>>>>>
>>>>>> I would like to know if Camel can read an uri like this (from
>>>>>> uri="activemq:topic:stock.*") where the star represents any topic
>>>>>> created
>>>>>> with the root name STOCK. ?
>>>>>
>>>>> Yes
>>>>>
>>>>> --
>>>>> James
>>>>> -------
>>>>> http://macstrac.blogspot.com/
>>>>>
>>>>> Open Source Integration
>>>>> http://fusesource.com/
>>>>>
>>>>>
>>>>
>>>>
>>>> -----
>>>> Enterprise Architect
>>>>
>>>> Xpectis
>>>> 12, route d'Esch
>>>> L-1470 Luxembourg
>>>>
>>>> Phone +352 25 10 70 470
>>>> Mobile +352 621 45 36 22
>>>>
>>>> e-mail : cmoulliard@xpectis.com
>>>> web site : www.xpectis.com www.xpectis.com
>>>> My Blog : http://cmoulliard.blogspot.com/
>>>> http://cmoulliard.blogspot.com/
>>>> --
>>>> View this message in context:
>>>> http://www.nabble.com/Can-Camel-read-an-uri-like-this-%22activemq%3Atopic%3Astock.*%22----tp20305361s22882p20305700.html
>>>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>>>
>>>>
>>>
>>>
>>>
>>> --
>>> James
>>> -------
>>> http://macstrac.blogspot.com/
>>>
>>> Open Source Integration
>>> http://fusesource.com/
>>>
>>>
>>
>>
>> -----
>> Enterprise Architect
>>
>> Xpectis
>> 12, route d'Esch
>> L-1470 Luxembourg
>>
>> Phone +352 25 10 70 470
>> Mobile +352 621 45 36 22
>>
>> e-mail : cmoulliard@xpectis.com
>> web site : www.xpectis.com www.xpectis.com
>> My Blog : http://cmoulliard.blogspot.com/
>> http://cmoulliard.blogspot.com/
>> --
>> View this message in context:
>> http://www.nabble.com/Can-Camel-read-an-uri-like-this-%22activemq%3Atopic%3Astock.*%22----tp20305361s22882p20305976.html
>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>
>>
>
>
>
> --
> James
> -------
> http://macstrac.blogspot.com/
>
> Open Source Integration
> http://fusesource.com/
>
>
-----
Enterprise Architect
Xpectis
12, route d'Esch
L-1470 Luxembourg
Phone +352 25 10 70 470
Mobile +352 621 45 36 22
e-mail : cmoulliard@xpectis.com
web site : www.xpectis.com www.xpectis.com
My Blog : http://cmoulliard.blogspot.com/ http://cmoulliard.blogspot.com/
--
View this message in context: http://www.nabble.com/Can-Camel-read-an-uri-like-this-%22activemq%3Atopic%3Astock.*%22----tp20305361s22882p20306225.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Can Camel read an uri like this "activemq:topic:stock.*" ?
Posted by James Strachan <ja...@gmail.com>.
If you send a message to a jms:topic.STOCK.FOO does it work?
Does your {$in.header.stock} contain any dots?
2008/11/3 cmoulliard <cm...@gmail.com>:
>
> Unfortunately, removing the // does not help :
>
> <recipientList>
> <simple>jms:topic:STOCK.${in.header.stock}</simple>
> </recipientList>
> </splitter>
> </route>
> <route>
> <from uri="jms:topic:STOCK.*" />
>
>
> James.Strachan wrote:
>>
>> Try use the URI you said - jms:topic.STOCK.* rather than
>> jms:topic.//STOCK.*
>>
>> 2008/11/3 cmoulliard <cm...@gmail.com>:
>>>
>>> This is strange because the following routing does not work
>>>
>>> <?xml version="1.0" encoding="UTF-8"?>
>>> <beans xmlns="http://www.springframework.org/schema/beans"
>>> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
>>> xmlns:context="http://www.springframework.org/schema/context"
>>> xsi:schemaLocation="
>>> http://www.springframework.org/schema/beans
>>> http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
>>> http://www.springframework.org/schema/context
>>>
>>> http://www.springframework.org/schema/context/spring-context-2.5.xsd
>>> http://activemq.apache.org/camel/schema/spring
>>> http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">
>>>
>>> <!-- ActiveMQ brokerURL using VM protocol -->
>>> <bean id="jms"
>>> class="org.apache.activemq.camel.component.ActiveMQComponent">
>>> <property name="brokerURL"
>>>
>>> value="vm://localhost:61616?broker.persistent=true" />
>>> </bean>
>>>
>>> <!-- This config does not work
>>> <bean id="jms"
>>> class="org.apache.camel.component.jms.JmsComponent">
>>> <property name="connectionFactory">
>>> <bean
>>> class="org.apache.activemq.ActiveMQConnectionFactory">
>>> <property name="brokerURL"
>>> value="vm://localhost:61616?broker.persistent=false" />
>>> </bean>
>>> </property>
>>> </bean>
>>> -->
>>>
>>> <bean id="camelTracer"
>>> class="org.apache.camel.processor.interceptor.Tracer">
>>> <property name="traceExceptions" value="false" />
>>> <property name="traceInterceptors" value="true" />
>>> <property name="logLevel" value="DEBUG" />
>>> <property name="logName" value="com.xpectis.tracker" />
>>> </bean>
>>>
>>> <bean id="traceFormatter"
>>> class="org.apache.camel.processor.interceptor.TraceFormatter">
>>> <property name="showBody" value="true" />
>>> <property name="showHeaders" value="true" />
>>> <property name="showBodyType" value="false" />
>>> <property name="showBreadCrumb" value="false" />
>>> </bean>
>>>
>>> <!-- Based on Formatter class but no more required since 1.5
>>> <bean id="myXstreamDataFormat" class="com.xpectis.model.Formatter"
>>> factory-method="createInstance">
>>> <constructor-arg value="com.xpectis.model.StockPrice" />
>>> </bean>
>>> -->
>>> <bean id="myXstreamDataFormat"
>>> class="org.apache.camel.dataformat.xstream.XStreamDataFormat"
>>> factory-method="processAnnotations">
>>> <constructor-arg value="com.xpectis.model.StockPrice" />
>>> </bean>
>>>
>>> <bean id="stockPriceGenerator"
>>> class="com.xpectis.service.common.impl.StockPriceGenerator" />
>>> <bean id="stockUpdater"
>>> class="com.xpectis.service.common.impl.StockUpdater" />
>>>
>>> <camelContext id="camel" trace="true"
>>> xmlns="http://activemq.apache.org/camel/schema/spring">
>>> <!-- <jmxAgent id="agent" createConnector="true" /> -->
>>> <route>
>>> <from
>>> uri="timer:generateStockPrice?fixedRate=true&delay=10000&period=5000"
>>> />
>>> <to uri="bean:stockPriceGenerator" />
>>> <marshal ref="myXstreamDataFormat" />
>>> <splitter>
>>> <xpath>//price</xpath>
>>> <setHeader headerName="stock">
>>> <xpath>//price/@stock</xpath>
>>> </setHeader>
>>> <recipientList>
>>>
>>> <simple>jms:topic://STOCK.${in.header.stock}</simple>
>>> </recipientList>
>>> </splitter>
>>> </route>
>>> <!-- everything works fine till here -->
>>>
>>> <route>
>>> <from uri="jms:topic://STOCK.*" />
>>> <unmarshal ref="myXstreamDataFormat" />
>>> <to uri="bean:stockUpdater" />
>>> <!-- nothing arrives at my bean -->
>>> </route>
>>>
>>> </camelContext>
>>>
>>> </beans>
>>>
>>>
>>>
>>> James.Strachan wrote:
>>>>
>>>> 2008/11/3 cmoulliard <cm...@gmail.com>:
>>>>>
>>>>> Hi,
>>>>>
>>>>> I would like to know if Camel can read an uri like this (from
>>>>> uri="activemq:topic:stock.*") where the star represents any topic
>>>>> created
>>>>> with the root name STOCK. ?
>>>>
>>>> Yes
>>>>
>>>> --
>>>> James
>>>> -------
>>>> http://macstrac.blogspot.com/
>>>>
>>>> Open Source Integration
>>>> http://fusesource.com/
>>>>
>>>>
>>>
>>>
>>> -----
>>> Enterprise Architect
>>>
>>> Xpectis
>>> 12, route d'Esch
>>> L-1470 Luxembourg
>>>
>>> Phone +352 25 10 70 470
>>> Mobile +352 621 45 36 22
>>>
>>> e-mail : cmoulliard@xpectis.com
>>> web site : www.xpectis.com www.xpectis.com
>>> My Blog : http://cmoulliard.blogspot.com/
>>> http://cmoulliard.blogspot.com/
>>> --
>>> View this message in context:
>>> http://www.nabble.com/Can-Camel-read-an-uri-like-this-%22activemq%3Atopic%3Astock.*%22----tp20305361s22882p20305700.html
>>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>>
>>>
>>
>>
>>
>> --
>> James
>> -------
>> http://macstrac.blogspot.com/
>>
>> Open Source Integration
>> http://fusesource.com/
>>
>>
>
>
> -----
> Enterprise Architect
>
> Xpectis
> 12, route d'Esch
> L-1470 Luxembourg
>
> Phone +352 25 10 70 470
> Mobile +352 621 45 36 22
>
> e-mail : cmoulliard@xpectis.com
> web site : www.xpectis.com www.xpectis.com
> My Blog : http://cmoulliard.blogspot.com/ http://cmoulliard.blogspot.com/
> --
> View this message in context: http://www.nabble.com/Can-Camel-read-an-uri-like-this-%22activemq%3Atopic%3Astock.*%22----tp20305361s22882p20305976.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
>
--
James
-------
http://macstrac.blogspot.com/
Open Source Integration
http://fusesource.com/
Re: Can Camel read an uri like this "activemq:topic:stock.*" ?
Posted by cmoulliard <cm...@gmail.com>.
Unfortunately, removing the // does not help :
<recipientList>
<simple>jms:topic:STOCK.${in.header.stock}</simple>
</recipientList>
</splitter>
</route>
<route>
<from uri="jms:topic:STOCK.*" />
James.Strachan wrote:
>
> Try use the URI you said - jms:topic.STOCK.* rather than
> jms:topic.//STOCK.*
>
> 2008/11/3 cmoulliard <cm...@gmail.com>:
>>
>> This is strange because the following routing does not work
>>
>> <?xml version="1.0" encoding="UTF-8"?>
>> <beans xmlns="http://www.springframework.org/schema/beans"
>> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
>> xmlns:context="http://www.springframework.org/schema/context"
>> xsi:schemaLocation="
>> http://www.springframework.org/schema/beans
>> http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
>> http://www.springframework.org/schema/context
>>
>> http://www.springframework.org/schema/context/spring-context-2.5.xsd
>> http://activemq.apache.org/camel/schema/spring
>> http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">
>>
>> <!-- ActiveMQ brokerURL using VM protocol -->
>> <bean id="jms"
>> class="org.apache.activemq.camel.component.ActiveMQComponent">
>> <property name="brokerURL"
>>
>> value="vm://localhost:61616?broker.persistent=true" />
>> </bean>
>>
>> <!-- This config does not work
>> <bean id="jms"
>> class="org.apache.camel.component.jms.JmsComponent">
>> <property name="connectionFactory">
>> <bean
>> class="org.apache.activemq.ActiveMQConnectionFactory">
>> <property name="brokerURL"
>> value="vm://localhost:61616?broker.persistent=false" />
>> </bean>
>> </property>
>> </bean>
>> -->
>>
>> <bean id="camelTracer"
>> class="org.apache.camel.processor.interceptor.Tracer">
>> <property name="traceExceptions" value="false" />
>> <property name="traceInterceptors" value="true" />
>> <property name="logLevel" value="DEBUG" />
>> <property name="logName" value="com.xpectis.tracker" />
>> </bean>
>>
>> <bean id="traceFormatter"
>> class="org.apache.camel.processor.interceptor.TraceFormatter">
>> <property name="showBody" value="true" />
>> <property name="showHeaders" value="true" />
>> <property name="showBodyType" value="false" />
>> <property name="showBreadCrumb" value="false" />
>> </bean>
>>
>> <!-- Based on Formatter class but no more required since 1.5
>> <bean id="myXstreamDataFormat" class="com.xpectis.model.Formatter"
>> factory-method="createInstance">
>> <constructor-arg value="com.xpectis.model.StockPrice" />
>> </bean>
>> -->
>> <bean id="myXstreamDataFormat"
>> class="org.apache.camel.dataformat.xstream.XStreamDataFormat"
>> factory-method="processAnnotations">
>> <constructor-arg value="com.xpectis.model.StockPrice" />
>> </bean>
>>
>> <bean id="stockPriceGenerator"
>> class="com.xpectis.service.common.impl.StockPriceGenerator" />
>> <bean id="stockUpdater"
>> class="com.xpectis.service.common.impl.StockUpdater" />
>>
>> <camelContext id="camel" trace="true"
>> xmlns="http://activemq.apache.org/camel/schema/spring">
>> <!-- <jmxAgent id="agent" createConnector="true" /> -->
>> <route>
>> <from
>> uri="timer:generateStockPrice?fixedRate=true&delay=10000&period=5000"
>> />
>> <to uri="bean:stockPriceGenerator" />
>> <marshal ref="myXstreamDataFormat" />
>> <splitter>
>> <xpath>//price</xpath>
>> <setHeader headerName="stock">
>> <xpath>//price/@stock</xpath>
>> </setHeader>
>> <recipientList>
>>
>> <simple>jms:topic://STOCK.${in.header.stock}</simple>
>> </recipientList>
>> </splitter>
>> </route>
>> <!-- everything works fine till here -->
>>
>> <route>
>> <from uri="jms:topic://STOCK.*" />
>> <unmarshal ref="myXstreamDataFormat" />
>> <to uri="bean:stockUpdater" />
>> <!-- nothing arrives at my bean -->
>> </route>
>>
>> </camelContext>
>>
>> </beans>
>>
>>
>>
>> James.Strachan wrote:
>>>
>>> 2008/11/3 cmoulliard <cm...@gmail.com>:
>>>>
>>>> Hi,
>>>>
>>>> I would like to know if Camel can read an uri like this (from
>>>> uri="activemq:topic:stock.*") where the star represents any topic
>>>> created
>>>> with the root name STOCK. ?
>>>
>>> Yes
>>>
>>> --
>>> James
>>> -------
>>> http://macstrac.blogspot.com/
>>>
>>> Open Source Integration
>>> http://fusesource.com/
>>>
>>>
>>
>>
>> -----
>> Enterprise Architect
>>
>> Xpectis
>> 12, route d'Esch
>> L-1470 Luxembourg
>>
>> Phone +352 25 10 70 470
>> Mobile +352 621 45 36 22
>>
>> e-mail : cmoulliard@xpectis.com
>> web site : www.xpectis.com www.xpectis.com
>> My Blog : http://cmoulliard.blogspot.com/
>> http://cmoulliard.blogspot.com/
>> --
>> View this message in context:
>> http://www.nabble.com/Can-Camel-read-an-uri-like-this-%22activemq%3Atopic%3Astock.*%22----tp20305361s22882p20305700.html
>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>
>>
>
>
>
> --
> James
> -------
> http://macstrac.blogspot.com/
>
> Open Source Integration
> http://fusesource.com/
>
>
-----
Enterprise Architect
Xpectis
12, route d'Esch
L-1470 Luxembourg
Phone +352 25 10 70 470
Mobile +352 621 45 36 22
e-mail : cmoulliard@xpectis.com
web site : www.xpectis.com www.xpectis.com
My Blog : http://cmoulliard.blogspot.com/ http://cmoulliard.blogspot.com/
--
View this message in context: http://www.nabble.com/Can-Camel-read-an-uri-like-this-%22activemq%3Atopic%3Astock.*%22----tp20305361s22882p20305976.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Can Camel read an uri like this "activemq:topic:stock.*" ?
Posted by James Strachan <ja...@gmail.com>.
Try use the URI you said - jms:topic.STOCK.* rather than jms:topic.//STOCK.*
2008/11/3 cmoulliard <cm...@gmail.com>:
>
> This is strange because the following routing does not work
>
> <?xml version="1.0" encoding="UTF-8"?>
> <beans xmlns="http://www.springframework.org/schema/beans"
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xmlns:context="http://www.springframework.org/schema/context"
> xsi:schemaLocation="
> http://www.springframework.org/schema/beans
> http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
> http://www.springframework.org/schema/context
> http://www.springframework.org/schema/context/spring-context-2.5.xsd
> http://activemq.apache.org/camel/schema/spring
> http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">
>
> <!-- ActiveMQ brokerURL using VM protocol -->
> <bean id="jms"
> class="org.apache.activemq.camel.component.ActiveMQComponent">
> <property name="brokerURL"
> value="vm://localhost:61616?broker.persistent=true" />
> </bean>
>
> <!-- This config does not work
> <bean id="jms" class="org.apache.camel.component.jms.JmsComponent">
> <property name="connectionFactory">
> <bean class="org.apache.activemq.ActiveMQConnectionFactory">
> <property name="brokerURL"
> value="vm://localhost:61616?broker.persistent=false" />
> </bean>
> </property>
> </bean>
> -->
>
> <bean id="camelTracer"
> class="org.apache.camel.processor.interceptor.Tracer">
> <property name="traceExceptions" value="false" />
> <property name="traceInterceptors" value="true" />
> <property name="logLevel" value="DEBUG" />
> <property name="logName" value="com.xpectis.tracker" />
> </bean>
>
> <bean id="traceFormatter"
> class="org.apache.camel.processor.interceptor.TraceFormatter">
> <property name="showBody" value="true" />
> <property name="showHeaders" value="true" />
> <property name="showBodyType" value="false" />
> <property name="showBreadCrumb" value="false" />
> </bean>
>
> <!-- Based on Formatter class but no more required since 1.5
> <bean id="myXstreamDataFormat" class="com.xpectis.model.Formatter"
> factory-method="createInstance">
> <constructor-arg value="com.xpectis.model.StockPrice" />
> </bean>
> -->
> <bean id="myXstreamDataFormat"
> class="org.apache.camel.dataformat.xstream.XStreamDataFormat"
> factory-method="processAnnotations">
> <constructor-arg value="com.xpectis.model.StockPrice" />
> </bean>
>
> <bean id="stockPriceGenerator"
> class="com.xpectis.service.common.impl.StockPriceGenerator" />
> <bean id="stockUpdater"
> class="com.xpectis.service.common.impl.StockUpdater" />
>
> <camelContext id="camel" trace="true"
> xmlns="http://activemq.apache.org/camel/schema/spring">
> <!-- <jmxAgent id="agent" createConnector="true" /> -->
> <route>
> <from
> uri="timer:generateStockPrice?fixedRate=true&delay=10000&period=5000"
> />
> <to uri="bean:stockPriceGenerator" />
> <marshal ref="myXstreamDataFormat" />
> <splitter>
> <xpath>//price</xpath>
> <setHeader headerName="stock">
> <xpath>//price/@stock</xpath>
> </setHeader>
> <recipientList>
> <simple>jms:topic://STOCK.${in.header.stock}</simple>
> </recipientList>
> </splitter>
> </route>
> <!-- everything works fine till here -->
>
> <route>
> <from uri="jms:topic://STOCK.*" />
> <unmarshal ref="myXstreamDataFormat" />
> <to uri="bean:stockUpdater" />
> <!-- nothing arrives at my bean -->
> </route>
>
> </camelContext>
>
> </beans>
>
>
>
> James.Strachan wrote:
>>
>> 2008/11/3 cmoulliard <cm...@gmail.com>:
>>>
>>> Hi,
>>>
>>> I would like to know if Camel can read an uri like this (from
>>> uri="activemq:topic:stock.*") where the star represents any topic created
>>> with the root name STOCK. ?
>>
>> Yes
>>
>> --
>> James
>> -------
>> http://macstrac.blogspot.com/
>>
>> Open Source Integration
>> http://fusesource.com/
>>
>>
>
>
> -----
> Enterprise Architect
>
> Xpectis
> 12, route d'Esch
> L-1470 Luxembourg
>
> Phone +352 25 10 70 470
> Mobile +352 621 45 36 22
>
> e-mail : cmoulliard@xpectis.com
> web site : www.xpectis.com www.xpectis.com
> My Blog : http://cmoulliard.blogspot.com/ http://cmoulliard.blogspot.com/
> --
> View this message in context: http://www.nabble.com/Can-Camel-read-an-uri-like-this-%22activemq%3Atopic%3Astock.*%22----tp20305361s22882p20305700.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
>
--
James
-------
http://macstrac.blogspot.com/
Open Source Integration
http://fusesource.com/
Re: Can Camel read an uri like this "activemq:topic:stock.*" ?
Posted by cmoulliard <cm...@gmail.com>.
This is strange because the following routing does not work
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-2.5.xsd
http://activemq.apache.org/camel/schema/spring
http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">
<!-- ActiveMQ brokerURL using VM protocol -->
<bean id="jms"
class="org.apache.activemq.camel.component.ActiveMQComponent">
<property name="brokerURL"
value="vm://localhost:61616?broker.persistent=true" />
</bean>
<!-- This config does not work
<bean id="jms" class="org.apache.camel.component.jms.JmsComponent">
<property name="connectionFactory">
<bean class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL"
value="vm://localhost:61616?broker.persistent=false" />
</bean>
</property>
</bean>
-->
<bean id="camelTracer"
class="org.apache.camel.processor.interceptor.Tracer">
<property name="traceExceptions" value="false" />
<property name="traceInterceptors" value="true" />
<property name="logLevel" value="DEBUG" />
<property name="logName" value="com.xpectis.tracker" />
</bean>
<bean id="traceFormatter"
class="org.apache.camel.processor.interceptor.TraceFormatter">
<property name="showBody" value="true" />
<property name="showHeaders" value="true" />
<property name="showBodyType" value="false" />
<property name="showBreadCrumb" value="false" />
</bean>
<!-- Based on Formatter class but no more required since 1.5
<bean id="myXstreamDataFormat" class="com.xpectis.model.Formatter"
factory-method="createInstance">
<constructor-arg value="com.xpectis.model.StockPrice" />
</bean>
-->
<bean id="myXstreamDataFormat"
class="org.apache.camel.dataformat.xstream.XStreamDataFormat"
factory-method="processAnnotations">
<constructor-arg value="com.xpectis.model.StockPrice" />
</bean>
<bean id="stockPriceGenerator"
class="com.xpectis.service.common.impl.StockPriceGenerator" />
<bean id="stockUpdater"
class="com.xpectis.service.common.impl.StockUpdater" />
<camelContext id="camel" trace="true"
xmlns="http://activemq.apache.org/camel/schema/spring">
<!-- <jmxAgent id="agent" createConnector="true" /> -->
<route>
<from
uri="timer:generateStockPrice?fixedRate=true&delay=10000&period=5000"
/>
<to uri="bean:stockPriceGenerator" />
<marshal ref="myXstreamDataFormat" />
<splitter>
<xpath>//price</xpath>
<setHeader headerName="stock">
<xpath>//price/@stock</xpath>
</setHeader>
<recipientList>
<simple>jms:topic://STOCK.${in.header.stock}</simple>
</recipientList>
</splitter>
</route>
<!-- everything works fine till here -->
<route>
<from uri="jms:topic://STOCK.*" />
<unmarshal ref="myXstreamDataFormat" />
<to uri="bean:stockUpdater" />
<!-- nothing arrives at my bean -->
</route>
</camelContext>
</beans>
James.Strachan wrote:
>
> 2008/11/3 cmoulliard <cm...@gmail.com>:
>>
>> Hi,
>>
>> I would like to know if Camel can read an uri like this (from
>> uri="activemq:topic:stock.*") where the star represents any topic created
>> with the root name STOCK. ?
>
> Yes
>
> --
> James
> -------
> http://macstrac.blogspot.com/
>
> Open Source Integration
> http://fusesource.com/
>
>
-----
Enterprise Architect
Xpectis
12, route d'Esch
L-1470 Luxembourg
Phone +352 25 10 70 470
Mobile +352 621 45 36 22
e-mail : cmoulliard@xpectis.com
web site : www.xpectis.com www.xpectis.com
My Blog : http://cmoulliard.blogspot.com/ http://cmoulliard.blogspot.com/
--
View this message in context: http://www.nabble.com/Can-Camel-read-an-uri-like-this-%22activemq%3Atopic%3Astock.*%22----tp20305361s22882p20305700.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Can Camel read an uri like this "activemq:topic:stock.*" ?
Posted by James Strachan <ja...@gmail.com>.
2008/11/3 cmoulliard <cm...@gmail.com>:
>
> Hi,
>
> I would like to know if Camel can read an uri like this (from
> uri="activemq:topic:stock.*") where the star represents any topic created
> with the root name STOCK. ?
Yes
--
James
-------
http://macstrac.blogspot.com/
Open Source Integration
http://fusesource.com/