ActiveMQ Producer/Consumer + SpringBoot RestAPIs example

In the tutorial, we show how to build SpringBoot RestAPIs to produce/consume data from ActiveMQ.

Related posts:
– Spring Jms ActiveMq – How to send Java object messages to ActiveMQ server (specially with Bi-Directional relationship Java objects)
– How to use Spring JMS with ActiveMQ – JMS Consumer and JMS Producer | Spring Boot
– ActiveMq – Explicitly configure Spring ActiveMq ConnectionFactory with SpringBoot
– ActiveMq – How to work with Spring JMS ActiveMq Topic (Publisher-Subcribers pattern) using SpringBoot

Technologies

• Java 1.8
• Maven 3.3.9
• Spring Tool Suite – Version 3.9.4.RELEASE
• Spring Boot: 2.0.3.RELEASE
• ActiveMQ

Practice

We create a Spring JMS ActiveMQ with JMS Producer & JMS Consumer as below:

Then expose RestAPIs to POST/GET data to/from ActiveMQ:

• @PostMapping(value="/api/customer")
• @GetMapping(value="/api/customers")

Setup SpringBoot project

Use SpringToolSuite to create a SpringBoot project with below dependencies:

	org.springframework
	spring-jms


	org.apache.activemq
	activemq-broker


	org.springframework.boot
	spring-boot-starter-web

ActiveMQ Connection Factory

ActiveMqConnectionFactoryConfig ->

package com.grokonez.activemq.config;

import javax.jms.ConnectionFactory;

import org.apache.activemq.ActiveMQConnectionFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.jms.DefaultJmsListenerContainerFactoryConfigurer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jms.config.DefaultJmsListenerContainerFactory;
import org.springframework.jms.config.JmsListenerContainerFactory;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.support.converter.MappingJackson2MessageConverter;
import org.springframework.jms.support.converter.MessageConverter;
import org.springframework.jms.support.converter.MessageType;

@Configuration
public class ActiveMqConnectionFactoryConfig {

	@Value("${gkz.activemq.broker.url}")
	String brokerUrl;
	
	@Value("${gkz.activemq.borker.username}")
	String userName;
	
	@Value("${gkz.activemq.borker.password}")
	String password;

	/*
	 * Initial ConnectionFactory
	 */
    @Bean
    public ConnectionFactory connectionFactory(){
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
        connectionFactory.setBrokerURL(brokerUrl);
        connectionFactory.setUserName(userName);
        connectionFactory.setPassword(password);
        return connectionFactory;
    }
    
	@Bean // Serialize message content to json using TextMessage
	public MessageConverter jacksonJmsMessageConverter() {
	    MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
	    converter.setTargetType(MessageType.TEXT);
	    converter.setTypeIdPropertyName("_type");
	    return converter;
	}
    
    /*
     * Used for Receiving Message
     */
    @Bean
    public JmsListenerContainerFactory jsaFactory(ConnectionFactory connectionFactory,
                                                    DefaultJmsListenerContainerFactoryConfigurer configurer) {
        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
        factory.setMessageConverter(jacksonJmsMessageConverter());
        configurer.configure(factory, connectionFactory);
        return factory;
    }
 
    /*
     * Used for Sending Messages.
     */
    @Bean
    public JmsTemplate jmsTemplate(){
        JmsTemplate template = new JmsTemplate();
        template.setMessageConverter(jacksonJmsMessageConverter());
        template.setConnectionFactory(connectionFactory());
        return template;
    }
}

Add ActiveMQ configuration in application.properties ->

gkz.activemq.broker.url=tcp://localhost:61616
gkz.activemq.borker.username=admin
gkz.activemq.borker.password=admin
gkz.activemq.queue=gkz-queue

Data Model

– Create Customer model ->

package com.grokonez.activemq.model;

public class Customer {
	private Long id;
	private String firstname;
	private String lastname;
	private int age;
	
	public Customer(){
	}
	
	public Customer(String firstname, String lastname, int age){
		this.firstname = firstname;
		this.lastname = lastname;
		this.age = age;
	}
	
	public Customer(Long id, String firstname, String lastname, int age){
		this.id = id;
		this.firstname = firstname;
		this.lastname = lastname;
		this.age = age;
	}
	
	// id
	public void setId(Long id){
		this.id = id;
	}
	
	public Long getId(){
		return this.id;
	}
	
	// firstname
	public void setFirstname(String firstname){
		this.firstname = firstname;
	}
	
	public String getFirstname(){
		return this.firstname;
	}
	
	// lastname
	public void setLastname(String lastname){
		this.lastname = lastname;
	}
	
	public String getLastname(){
		return this.lastname;
	}
	
	// age
	public void setAge(int age){
		this.age = age;
	}
	
	public int getAge(){
		return this.age;
	}	
}

– Create MessageStorage to storage Customer list ->

package com.grokonez.activemq.model;

import java.util.ArrayList;
import java.util.List;

public class MessageStorage {
	private List customers = new ArrayList<>();
	
	public void add(Customer customer) {
		customers.add(customer);
	}
	
	public void clear() {
		customers.clear();
	}
	
	public List getAll(){
		return customers;
	}
}

Create a bean for MessageStorage ->

package com.grokonez.activemq.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import com.grokonez.activemq.model.MessageStorage;

@Configuration
public class BeanConfiguration {

  @Bean
  public MessageStorage customerStorage() {
    return new MessageStorage();
  }
}	

JMS Producer

JmsProducer send messages to ActiveMQ:

package com.grokonez.activemq.jms.producer;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Component;

import com.grokonez.activemq.model.Customer;

@Component
public class JmsProducer {
	@Autowired
	JmsTemplate jmsTemplate;
	
	@Value("${gkz.activemq.queue}")
	String queue;
	
	public void send(Customer customer){
		jmsTemplate.convertAndSend(queue, customer);
	}
}

JMS Consumer

JmsConsumer recieves messages from ActiveMQ ->

package com.grokonez.activemq.jms.consumer;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

import com.grokonez.activemq.model.Customer;
import com.grokonez.activemq.model.MessageStorage;

@Component
public class JmsConsumer {
	@Autowired
	private MessageStorage customerStorage;
	
	@JmsListener(destination = "${gkz.activemq.queue}", containerFactory="jsaFactory")
	public void receive(Customer customer){
		System.out.println("Recieved Message: " + customer);
		customerStorage.add(customer);
	}
}

Rest APIs

RestAPIs ->

package com.grokonez.activemq.controller;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;

import com.grokonez.activemq.jms.producer.JmsProducer;
import com.grokonez.activemq.model.Customer;
import com.grokonez.activemq.model.MessageStorage;

@RestController
public class RestAPIs {
	
	@Autowired
	JmsProducer jmsProducer;
	
	@Autowired
	private MessageStorage customerStorage;
	
	@PostMapping(value="/api/customer")
	public Customer postCustomer(@RequestBody Customer customer){
		jmsProducer.send(customer);
		return customer;
	}
	
	@GetMapping(value="/api/customers")
	public List getAll(){
		List customers = customerStorage.getAll();
		return customers;
	}
	
	@DeleteMapping(value="/api/customers/clear")
	public String clearCustomerStorage() {
		customerStorage.clear();
		return "Clear All CustomerStorage!";
	}
}

Run & Check Results

– Build & Run SpringBoot project with commandlines {mvn clean install, mvn spring-boot:run}.

-> Post Messages to ActiveMQ:

-> Get Messages:

-> ActiveMQ state:

SourceCode

SpringBootActiveMQ