Hello everyone, In this post, you will learn How to Send an Object to ActiveMQ using Apache Camel. The example has been tested and shared in the post.

Maven Dependencies


Example Program

package com.dineshkrish;
import java.util.Date;
import javax.jms.ConnectionFactory;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.camel.CamelContext;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.jms.JmsComponent;
import org.apache.camel.impl.DefaultCamelContext;
* @author Dinesh Krishnan
public class ObjectToActiveMQ {
public static void main(String[] args) throws Exception {
// create a camel context
CamelContext context = new DefaultCamelContext();
// creating connection for activeMQ
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://localhost");
context.addComponent("jms", JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));
try {
context.addRoutes(new RouteBuilder() {
public void configure() throws Exception {
// start the context
// create producer template
ProducerTemplate template = context.createProducerTemplate();
// create Date instance. 
// Note: you can send custom object too
Date date = new Date();
System.out.println("sent : " + date);
// send an object
template.sendBody("direct:start", date);
} catch (Exception e) {
// stop the context

No responses yet

Leave a Reply

Your email address will not be published. Required fields are marked *