Hi Willem, You are right that camel automatically set the exchange and routingkey, but it also sets the flag to autodelete=true, kindly give some guidance how we can pass parameters to camel to send persistent messages to Qpid.
Kind Regards willem.jiang wrote: > > 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. > > > -- View this message in context: http://www.nabble.com/URI-format-for-AMQP-topic---help-required-tp23442475p25292706.html Sent from the Camel - Users (activemq) mailing list archive at Nabble.com.