Getting Started with Message Queue (ActiveMQ )

The message queue paradigm is a sibling of the publisher/subscriber pattern, and is typically one part of a larger message-oriented middleware system. Most messaging systems support both the publisher/subscriber and message queue models in their API, e.g. Java Message Service (JMS).

Apache ActiveMQ is the most popular open source, multi-protocol, Java-based message broker.

Requirements:

JDK 8
Intellij
ActiveMQ 5.16.4

Download ActiveMQ 5.16.4

Extrac All, and enter on bin/win64, double clic activemq

localhost-queue

User and password for default is admin, admin

Create new queue

Publisher

ConnectionFactory factory = new ActiveMQConnectionFactory("admin", "admin","tcp://localhost:61616");        
try {
Connection connection = factory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("test_queue");

// M E S S A G E
String[] messages = {"First Message", "Second Message", "Thrid Message", "Fourth Message"};

// P R O D U C E R
MessageProducer producer = session.createProducer(destination);

for (String message : messages) {
TextMessage textMessage = session.createTextMessage(message);
producer.send(textMessage);
}           
System.out.println("Message Published");
session.close();
connection.close();

Consumer

ConnectionFactory factory = new ActiveMQConnectionFactory("admin", "admin","tcp://localhost:61616");

try {
Connection connection = factory.createConnection();
connection.start();

Session session = connection.createSession(false,Session.CLIENT_ACKNOWLEDGE);
Destination destination = session.createQueue("test_queue");
MessageConsumer consumer = session.createConsumer(destination);
consumer.setMessageListener(new MessageListener() {

public void onMessage(Message message) {
TextMessage textMessage = (TextMessage) message;
try {
 System.out.println(textMessage.getText());
 textMessage.acknowledge();
} catch (JMSException e) {
 e.printStackTrace();
}
}
});
} catch (JMSException e) {
 e.printStackTrace();
}