ActiveMQ Implementation

Author: Tharindu714

.idea/vcs.xml

@@ -0,0 +1,38 @@
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### IntelliJ IDEA ###
+.idea/modules.xml
+.idea/jarRepositories.xml
+.idea/compiler.xml
+.idea/libraries/
+*.iws
+*.iml
+*.ipr
+
+### Eclipse ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/
+
+### Mac OS ###
+.DS_Store

ActiveMQ-Client/.gitignore

@@ -0,0 +1,30 @@
+<?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.deltacodex.ee</groupId>
+    <artifactId>ActiveMQ-Client</artifactId>
+    <version>1.0</version>
+
+    <properties>
+        <maven.compiler.source>11</maven.compiler.source>
+        <maven.compiler.target>11</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.apache.activemq</groupId>
+            <artifactId>activemq-all</artifactId>
+            <version>5.18.6</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.logging.log4j</groupId>
+            <artifactId>log4j-core</artifactId>
+            <version>2.23.1</version>
+        </dependency>
+    </dependencies>
+
+</project>

ActiveMQ-Client/.idea/.gitignore

@@ -0,0 +1,39 @@
+package com.deltacodex.ee.activemq;
+
+import org.apache.activemq.ActiveMQConnectionFactory;
+
+import javax.jms.*;
+
+public class MessageReceiver {
+    public static void main(String[] args) {
+        ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
+        try {
+            Connection connection = activeMQConnectionFactory.createConnection();
+            connection.setClientID("ActiveMQ-ClientApp-1.1.0");
+            connection.start();
+
+            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+            Topic topic = session.createTopic("activeMQTopic");
+
+            MessageConsumer consumer = session.createConsumer(topic);
+            consumer.setMessageListener(new MessageListener() {
+                public void onMessage(Message message) {
+                    try {
+                        System.out.println("Received message: " + message.getBody(String.class));
+                    } catch (JMSException e) {
+                        throw new RuntimeException(e);
+                    }
+                }
+            });
+
+            while (true) {}
+
+//            consumer.close();
+//            session.close();
+//            connection.close();
+
+        } catch (JMSException e) {
+            throw new RuntimeException(e);
+        }
+    }
+}

ActiveMQ-Client/.idea/encodings.xml

@@ -0,0 +1,30 @@
+package com.deltacodex.ee.activemq;
+
+import org.apache.activemq.ActiveMQConnectionFactory;
+
+import javax.jms.*;
+
+public class MessageSender {
+    public static void main(String[] args) {
+        ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
+        try {
+            Connection connection = activeMQConnectionFactory.createConnection();
+            connection.setClientID("ActiveMQ-ClientApp-1.0.0");
+            connection.start();
+
+            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+            Topic topic = session.createTopic("activeMQTopic");
+
+            MessageProducer producer = session.createProducer(topic);
+            TextMessage textMessage = session.createTextMessage("Hello, This is ActiveMQ Message Sender");
+            producer.send(textMessage);
+
+            producer.close();
+            session.close();
+            connection.close();
+
+        } catch (JMSException e) {
+            throw new RuntimeException(e);
+        }
+    }
+}

ActiveMQ-Client/.idea/misc.xml

@@ -0,0 +1,36 @@
+package com.tharindu.me.auctionSystem.web.jms.message;
+
+import jakarta.annotation.PostConstruct;
+import jakarta.ejb.ActivationConfigProperty;
+import jakarta.ejb.MessageDriven;
+import jakarta.jms.JMSException;
+import jakarta.jms.Message;
+import jakarta.jms.MessageListener;
+
+//Message Driven Bean
+@MessageDriven(activationConfig = {
+//        @ActivationConfigProperty(propertyName = "destinationLookup", propertyValue = "jms/myQueue"), //For Queue Connections
+        @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "jakarta.jms.Topic"),
+        @ActivationConfigProperty(propertyName = "destinationLookup", propertyValue = "activeMQTopic"),
+        @ActivationConfigProperty(propertyName = "destination", propertyValue = "activeMQTopic"),
+        @ActivationConfigProperty(propertyName = "resourceAdapter", propertyValue = "activemq-rar-6.1.6"),
+        //@ActivationConfigProperty(propertyName = "maxPoolSize", propertyValue = "1"), //Server-specific -->> (maxSession or maxPoolSize)
+        //@ActivationConfigProperty(propertyName = "poolResizeQuantity", propertyValue = "1"), //Server-specific
+})
+public class MessageReceiver implements MessageListener {
+
+    @PostConstruct
+    public void init() {
+        System.out.println("MessageReceiver init...");
+    }
+
+    @Override
+    public void onMessage(Message message) {
+        try {
+            System.out.println(this + " Received message: "+message.getJMSMessageID()+" : " + message.getBody(String.class));
+            //OUTPUT >> com.deltacodex.ee.jms.web.message.MessageReceiver@75cecc43 Received message: ID:57-192.168.57.55(98:a2:ee:3e:d1:ab)-60700-1746737930643 : I'm JMS Provider 49
+        } catch (JMSException e) {
+            throw new RuntimeException(e);
+        }
+    }
+}