I'm using Apache Camel with Spring to handle consuming / publishing messages
with the Apache Qpid Java message broker. My Spring configuration file
contains:
<camel:camelContext id="camel">
<camel:route>
<camel:from uri="amqp:test-queue"/>
<camel:pipeline>
<camel:bean ref="myBean"/>
<camel:to uri="amqp:amq.topic"/>
</camel:pipeline>
</camel:route>
</camel:camelContext>
<bean id="amqp" class="org.apache.camel.component.amqp.AMQPComponent">
<property name="connectionFactory">
<bean class="org.apache.qpid.client.AMQConnectionFactory">
<constructor-arg index="0" type="java.lang.String"
value="amqp://guest:guest@/localhost?brokerlist='tcp://localhost:5672'" />
</bean>
</property>
</bean>
My app receives messages from queue test-queue OK, and they're forwarded to
myBean too. However, I don't know how to format the URI in the <camel:to
...> node above to post a message to the topic exchange amq.topic.
Using the RabbitMQ Java client, I can post a message with the code:
Channel channel = ...;
channel.exchangeDeclare("amq.topic", "topic");
channel.queueDeclare("test-other");
channel.queueBind("test-other", "amq.topic", "TEST");
channel.basicPublish("amq.topic", "TEST", null, messageBytes);
i.e. I post a message to a named exchange specifying a particular routing
key ("TEST" in this case).
How do I specify this information within the URI of the <camel:to ...> node?
Any help would be very much appreciated - thank you.
--
View this message in context:
http://www.nabble.com/URI-format-for-AMQP-topic---help-required-tp23442475p23442475.html
Sent from the Camel - Users (activemq) mailing list archive at Nabble.com.
