[CONF] Apache Camel: ActiveMQ (page edited)

Fri, 16 May 2008 10:26:36 -0700

Page Edited : CAMEL : ActiveMQ

ActiveMQ has been edited by Hiram Chirino (May 16, 2008).

(View changes)

Content:

ActiveMQ Component

The ActiveMQ component allows messages to be sent to a JMS Queue or Topic; or messages to be consumed from a JMS Queue or Topic using Apache ActiveMQ.

This component is based on the JMS Component and uses Spring's JMS support for declarative transactions, using Spring's JmsTemplate for sending and a MessageListenerContainer for consuming.

To use this component make sure you have the activemq.jar or activemq-core.jar on your classpath along with any Camel dependencies such as camel-core.jar, camel-spring.jar and camel-jms.jar.

URI format

activemq:[topic:]destinationName

So for example to send to queue FOO.BAR you would use





activemq:FOO.BAR





You can be completely specific if you wish via





activemq:queue:FOO.BAR






If you want to send to a topic called Stocks.Prices then you would use





activemq:topic:Stocks.Prices





Configuring the Connection Factory



The following test case shows how to add an ActiveMQComponent to the CamelContext using the activeMQComponent() method while specifying the brokerURL used to connect to ActiveMQ 





camelContext.addComponent("activemq", activeMQComponent("vm://localhost?broker.persistent=false"));





Configuring the Connection Factory using Spring XML



You can configure the ActiveMQ broker URL on the ActiveMQComponent as follows





<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="
       http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
       http://activemq.apache.org/camel/schema/spring http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">

  <camelContext xmlns="http://activemq.apache.org/camel/schema/spring">
  </camelContext>


  <bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent">
    <property name="brokerURL" value="tcp://somehost:61616"/>
  </bean>

</beans>





Invoking MessageListener POJOs in a Camel route



The ActiveMQ component also providers a helper Type Converter from a JMS MessageListener to a Processor. This means that the Bean component is capable of invoking any JMS MessageListener bean directly inside any route.



So for example you can create a MessageListener in JMS like this....





public class MyListener implements MessageListener {
   public void onMessage(Message jmsMessage) {
       // ...
   }
}





Then use it in your Camel route as follows




from("file://foo/bar").
  bean(MyListener.class);





i.e. you can reuse any of the Camel Components and easily integrate them into your JMS MessageListener POJO!



Getting Component JAR



The ActiveMQ Camel component is released with the ActiveMQ project itself.



For Maven 2 users you simply just need to add the following dependency to your project.





<dependency>
  <groupId>org.apache.activemq</groupId>
  <artifactId>activemq-core</artifactId>
  <version>5.1.0</version>
</dependency>





Alternatively you can download the component jar directly from the Maven repository:



activemq-core-5.1.0.jar



See Also

Powered by Atlassian Confluence (Version: 2.2.9 Build:#527 Sep 07, 2006) - Bug/feature request

Unsubscribe or edit your notifications preferences

Reply via email to