ActiveMQ and Java Consumer

ActiveMQ and Java Consumer
Start My Local Server from Console
> bin/activemq console
We can visit the Web Console then
http://127.0.0.1:8161/admin/
Default username/password is admin/admin. We can view and check the Queues.
The project name is  activemq-consumer
The pom.xml is as follow:
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.sillycat</groupId>
<artifactId>activemq-consumer</artifactId>
<version>1.0.0</version>
<name>ActiveMQ Consumer</name>
<description>ActiveMQ Consumer</description>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.1.1.RELEASE</version>
<relativePath />
</parent>
<properties>
<orika.version>1.5.1</orika.version>
</properties>
<dependencies>
<!-- spring-boot -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-webflux</artifactId>
<exclusions>
<exclusion>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-logging</artifactId>
</exclusion>
<exclusion>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-tomcat</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-core</artifactId>
<version>5.7.0</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jetty</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
</dependency>
<!-- tools -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
</dependency>
<dependency>
<groupId>ma.glasnost.orika</groupId>
<artifactId>orika-core</artifactId>
<version>${orika.version}</version>
</dependency>
<!-- logging -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-log4j2</artifactId>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>log4j-over-slf4j</artifactId>
</dependency>
<dependency>
<groupId>commons-httpclient</groupId>
<artifactId>commons-httpclient</artifactId>
<version>3.1</version>
</dependency>
<dependency>
<groupId>commons-discovery</groupId>
<artifactId>commons-discovery</artifactId>
<version>0.2</version>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger2</artifactId>
<version>2.9.2</version>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId>
<version>2.9.2</version>
</dependency>
<!-- Test -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>javax.servlet-api</artifactId>
<scope>provided</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<configuration>
<executable>true</executable>
</configuration>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-surefire-plugin</artifactId>
<configuration>
<excludes>
<exclude>**/*IntegrationTest.java</exclude>
</excludes>
</configuration>
</plugin>
</plugins>
</build>
<repositories>
<repository>
<id>spring-snapshots</id>
<url>http://repo.spring.io/snapshot</url>
<snapshots>
<enabled>true</enabled>
</snapshots>
</repository>
<repository>
<id>spring-milestones</id>
<url>http://repo.spring.io/milestone</url>
</repository>
</repositories>
<pluginRepositories>
<pluginRepository>
<id>spring-snapshots</id>
<url>http://repo.spring.io/snapshot</url>
</pluginRepository>
<pluginRepository>
<id>spring-milestones</id>
<url>http://repo.spring.io/milestone</url>
</pluginRepository>
</pluginRepositories>
</project>
The implementation class is as follow, ActiveMQServiceImpl.java
package com.sillycat.activemq;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
@Service
public class ActiveMQServiceImpl implements ActiveMQService {
    private static String url = "failover:(tcp://localhost:61616)";
    Session session;
    Connection connection;
    MessageProducer producer;
    MessageConsumer consumer;
    private void buildConnection() {
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
        try {
            this.connection = connectionFactory.createConnection();
            this.connection.start();
            this.session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            Queue queue = session.createQueue("dwh_datawarehouse" + "," + "dwh_datawarehouse-raw");
            this.producer = session.createProducer(queue);
            this.consumer = session.createConsumer(queue);
        } catch (JMSException e) {
            LOGGER.error("JMSException:", e);
        }
    }
    public String consumerMessage() {
        if (consumer == null) {
            this.buildConnection();
        }
        Message message;
        try {
            message = consumer.receive(1000);
            if (message instanceof TextMessage) {
                TextMessage textMessage = (TextMessage) message;
                String text = textMessage.getText();
                LOGGER.info("Received: " + text);
                return text;
            } else {
                LOGGER.info("Received: " + message);
                return message.toString();
            }
        } catch (JMSException e) {
            LOGGER.error("JMSException:", e);
        }
        return null;
    }
    public void produceMessage(String message) {
        if (producer == null) {
            this.buildConnection();
        }
        try {
            Message msg = session.createTextMessage(message);
            producer.send(msg);
        } catch (JMSException e) {
            LOGGER.error("JMSException:", e);
        }
    }
    public void releaseResource() {
        try {
            producer.close();
            consumer.close();
            session.close();
            connection.close();
        } catch (JMSException e) {
            LOGGER.error("JMSException:", e);
        }
    }
    protected final Logger LOGGER = LoggerFactory.getLogger(this.getClass());
}
No need to put the Interface here. Haha, I copy the project from a SpringBoot Project. So I need this class to run it.
package com.sillycat.activemq;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
@SpringBootApplication
public class ActiveMQApplication extends SpringBootServletInitializer {
    private static final Logger logger = LoggerFactory.getLogger(ActiveMQApplication.class);
    public static void main(String[] args) throws Exception {
        logger.info("ActiveMQApplication init! ");
        SpringApplication.run(ActiveMQApplication.class);
        logger.info("ActiveMQApplication started! ");
    }
    @Override
    protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
        return application.sources(ActiveMQApplication.class);
    }
}
The Unit Class ActiveMQServiceTest.java is  as follow:
package com.sillycat.activemq;
import org.junit.Assert;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
@RunWith(SpringRunner.class)
@SpringBootTest
public class ActiveMQServiceTest {
    @Autowired
    ActiveMQService activeMQService;
    @Test
    public void testBeanNotNull() {
        Assert.assertNotNull(activeMQService);
    }
    //@Test
    public void testProducer() {
        String message = "{ 'name': 'carl', 'testing':true}";
        activeMQService.produceMessage(message);
        activeMQService.releaseResource();
    }
   
    @Test
    public void testConsumer() {
        String message = activeMQService.consumerMessage();
        LOGGER.info("message:" + message);
        activeMQService.releaseResource();
    }
    protected final Logger LOGGER = LoggerFactory.getLogger(this.getClass());
}



References:
https://sillycat.iteye.com/blog/2433359