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.

Reply via email to