camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Willem Jiang <willem.ji...@gmail.com>
Subject Re: URI format for AMQP topic - help required
Date Fri, 08 May 2009 12:09:29 GMT
Hi,

I think you just need set the destinationName with topic queue's name.
Camel will create a exchage and set the correlation id (routing key) for
you.

Willem

gairey wrote:
> Ashwin, Willem,
> 
> Thanks for your prompt replies. I'm still having some trouble though. From
> my limited experience of using Qpid, it appears that when you consume
> messages, you specify a queue/topic name, whereas when you publish messages,
> you specify an exchange name and a routing key.
> 
> So, for the node:
> 
>   <camel:to uri="amqp:topic:destinationName"/>
> 
> I presume destinationName should be an exchange name? There doesn't seem to
> be a way of specifying the routing key though.
> 
> I've tried running my app with the above setting (i.e. destinationName set
> to the exchange amq.topic), but no messages are received by a JMS listener
> in a separate app, configured as follows (again using Spring):
> 
> <bean id="connectionFactory"
> class="org.apache.qpid.client.AMQConnectionFactory">
>   <constructor-arg index="0" type="java.lang.String"
> value="amqp://guest:guest@/localhost?brokerlist='tcp://localhost:5672'" />
> </bean>
> 
> <bean id="destination" class="org.apache.qpid.client.AMQTopic">
>   <constructor-arg index="0">
>     <bean class="org.apache.qpid.framing.AMQShortString">
>       <constructor-arg index="0" type="java.lang.String" value="amq.topic"
> />
>     </bean>
>   </constructor-arg>
>   <constructor-arg index="1" type="java.lang.String" value="TEST" />
> </bean>
> 
> <bean id="jmsConnection" class="org.springframework.jms.core.JmsTemplate"
> scope="prototype">
>   <property name="connectionFactory" ref="blazeConnectionFactory"/>
>   <property name="defaultDestination" ref="blazeDestination"/>
>   <property name="receiveTimeout" value="60000"/>
> </bean>
> 
> If I publish a message directly using the RabbitMQ client code in my
> previous post, the JMS listener does receive the message, so I'm pretty sure
> it's configured OK. 
> 
> Any ideas? Thanks again for your help so far - I'm pretty new to all this
> stuff, so really appreciate your time.


Mime
View raw message