Merge pull request #102 from TAMULib/b03883-weaver-messaging-module

B03883 weaver messaging module
TAMULib · May 1, 2019 · 930a84f · 930a84f
2 parents 90c59c9 + d1cc1b7
commit 930a84f
Show file tree

Hide file tree

Showing 16 changed files with 162 additions and 24 deletions.
diff --git a/auth/pom.xml b/auth/pom.xml
@@ -12,33 +12,33 @@
   <parent>
     <groupId>edu.tamu.weaver</groupId>
     <artifactId>webservice-parent</artifactId>
-    <version>2.0.0</version>
+    <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
   </parent>
 
   <dependencies>
 
     <dependency>
       <groupId>edu.tamu.weaver</groupId>
       <artifactId>core</artifactId>
-      <version>2.0.0</version>
+      <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
     </dependency>
 
     <dependency>
       <groupId>edu.tamu.weaver</groupId>
       <artifactId>user</artifactId>
-      <version>2.0.0</version>
+      <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
     </dependency>
 
     <dependency>
       <groupId>edu.tamu.weaver</groupId>
       <artifactId>token</artifactId>
-      <version>2.0.0</version>
+      <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
     </dependency>
 
     <dependency>
       <groupId>edu.tamu.weaver</groupId>
       <artifactId>email</artifactId>
-      <version>2.0.0</version>
+      <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
     </dependency>
 
     <dependency>

diff --git a/core/pom.xml b/core/pom.xml
@@ -12,7 +12,7 @@
   <parent>
     <groupId>edu.tamu.weaver</groupId>
     <artifactId>webservice-parent</artifactId>
-    <version>2.0.0</version>
+    <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
   </parent>
 
   <dependencies>

diff --git a/data/pom.xml b/data/pom.xml
@@ -12,15 +12,15 @@
   <parent>
     <groupId>edu.tamu.weaver</groupId>
     <artifactId>webservice-parent</artifactId>
-    <version>2.0.0</version>
+    <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
   </parent>
 
   <dependencies>
 
     <dependency>
       <groupId>edu.tamu.weaver</groupId>
       <artifactId>core</artifactId>
-      <version>2.0.0</version>
+      <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
     </dependency>
 
     <dependency>

diff --git a/email/pom.xml b/email/pom.xml
@@ -12,7 +12,7 @@
   <parent>
     <groupId>edu.tamu.weaver</groupId>
     <artifactId>webservice-parent</artifactId>
-    <version>2.0.0</version>
+    <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
   </parent>
 
   <dependencies>

diff --git a/messaging/pom.xml b/messaging/pom.xml
@@ -0,0 +1,32 @@
+<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/maven-v4_0_0.xsd">
+
+  <modelVersion>4.0.0</modelVersion>
+
+  <artifactId>messaging</artifactId>
+
+  <name>Weaver Messaging</name>
+
+  <description>Messaging for Weaver</description>
+
+  <parent>
+    <groupId>edu.tamu.weaver</groupId>
+    <artifactId>webservice-parent</artifactId>
+    <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
+  </parent>
+
+  <dependencies>
+
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-activemq</artifactId>
+    </dependency>
+
+    <dependency>
+      <groupId>com.fasterxml.jackson.core</groupId>
+      <artifactId>jackson-databind</artifactId>
+    </dependency>
+
+  </dependencies>
+
+</project>
diff --git a/messaging/src/main/java/edu/tamu/weaver/messaging/annotation/WeaverMessageListener.java b/messaging/src/main/java/edu/tamu/weaver/messaging/annotation/WeaverMessageListener.java
@@ -0,0 +1,25 @@
+package edu.tamu.weaver.messaging.annotation;
+
+import static java.lang.annotation.ElementType.METHOD;
+import static java.lang.annotation.RetentionPolicy.RUNTIME;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.Retention;
+import java.lang.annotation.Target;
+
+import org.springframework.core.annotation.AliasFor;
+import org.springframework.jms.annotation.JmsListener;
+
+@Documented
+@JmsListener(destination = "")
+@Retention(RUNTIME)
+@Target(METHOD)
+public @interface WeaverMessageListener {
+
+    @AliasFor(annotation = JmsListener.class, attribute = "destination")
+    String destination() default "default";
+
+    @AliasFor(annotation = JmsListener.class, attribute = "containerFactory")
+    String containerFactory() default "";
+
+}
diff --git a/messaging/src/main/java/edu/tamu/weaver/messaging/config/MessagingConfig.java b/messaging/src/main/java/edu/tamu/weaver/messaging/config/MessagingConfig.java
@@ -0,0 +1,46 @@
+package edu.tamu.weaver.messaging.config;
+
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Profile;
+import org.springframework.jms.config.DefaultJmsListenerContainerFactory;
+import org.springframework.jms.config.JmsListenerContainerFactory;
+import org.springframework.jms.connection.CachingConnectionFactory;
+import org.springframework.jms.core.JmsTemplate;
+
+@Configuration
+@Profile("weaver-messaging")
+public class MessagingConfig {
+
+    @Value("${spring.activemq.broker-url}")
+    private String brokerUrl;
+
+    @Bean
+    public CachingConnectionFactory cachingConnectionFactory() {
+        return new CachingConnectionFactory(defaultActiveMQConnectionFactory());
+    }
+
+    @Bean
+    public JmsTemplate jmsTopicTemplate() {
+        JmsTemplate jmsTemplate = new JmsTemplate(cachingConnectionFactory());
+        jmsTemplate.setPubSubDomain(true);
+        return jmsTemplate;
+    }
+
+    private ActiveMQConnectionFactory defaultActiveMQConnectionFactory() {
+        ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory();
+        activeMQConnectionFactory.setBrokerURL(brokerUrl);
+        return activeMQConnectionFactory;
+    }
+
+    @Bean
+    public JmsListenerContainerFactory<?> topicContainerFactory() {
+        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
+        factory.setConnectionFactory(defaultActiveMQConnectionFactory());
+        factory.setPubSubDomain(true);
+        return factory;
+    }
+
+}
diff --git a/messaging/src/main/java/edu/tamu/weaver/messaging/model/MessageAction.java b/messaging/src/main/java/edu/tamu/weaver/messaging/model/MessageAction.java
@@ -0,0 +1,5 @@
+package edu.tamu.weaver.messaging.model;
+
+public enum MessageAction {
+    CREATE, READ, UPDATE, DELETE, REFRESH;
+}
diff --git a/messaging/src/main/java/edu/tamu/weaver/messaging/service/MessagingService.java b/messaging/src/main/java/edu/tamu/weaver/messaging/service/MessagingService.java
@@ -0,0 +1,29 @@
+package edu.tamu.weaver.messaging.service;
+
+import java.util.Map;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Profile;
+import org.springframework.jms.core.JmsMessagingTemplate;
+import org.springframework.jms.core.JmsTemplate;
+import org.springframework.messaging.Message;
+import org.springframework.messaging.support.MessageBuilder;
+import org.springframework.stereotype.Service;
+
+@Service
+@Profile("weaver-messaging")
+public class MessagingService {
+
+    private final JmsMessagingTemplate jmsTemplate;
+
+    @Autowired
+    public MessagingService(JmsTemplate jmsTopicTemplate) {
+        this.jmsTemplate = new JmsMessagingTemplate(jmsTopicTemplate);
+    }
+
+    public void sendMessage(String destination, Map<String, String> payload) {
+        Message<Map<String, String>> message = MessageBuilder.withPayload(payload).build();
+        this.jmsTemplate.send(destination, message);
+    }
+
+}
diff --git a/pom.xml b/pom.xml
@@ -7,7 +7,7 @@
 
   <artifactId>webservice-parent</artifactId>
 
-  <version>2.0.0</version>
+  <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
 
   <name>Weaver Webservice Parent</name>
 
@@ -21,6 +21,7 @@
     <module>token</module>
     <module>user</module>
     <module>validation</module>
+    <module>messaging</module>
 
     <module>token-provider</module>
 

diff --git a/reporting/pom.xml b/reporting/pom.xml
@@ -12,21 +12,21 @@
   <parent>
     <groupId>edu.tamu.weaver</groupId>
     <artifactId>webservice-parent</artifactId>
-    <version>2.0.0</version>
+    <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
   </parent>
 
   <dependencies>
 
     <dependency>
       <groupId>edu.tamu.weaver</groupId>
       <artifactId>core</artifactId>
-      <version>2.0.0</version>
+      <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
     </dependency>
 
     <dependency>
       <groupId>edu.tamu.weaver</groupId>
       <artifactId>email</artifactId>
-      <version>2.0.0</version>
+      <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
     </dependency>
 
     <dependency>

diff --git a/token-provider/pom.xml b/token-provider/pom.xml
@@ -13,7 +13,7 @@
   <parent>
     <groupId>edu.tamu.weaver</groupId>
     <artifactId>webservice-parent</artifactId>
-    <version>2.0.0</version>
+    <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
   </parent>
 
   <dependencies>
@@ -26,13 +26,13 @@
     <dependency>
       <groupId>edu.tamu.weaver</groupId>
       <artifactId>token</artifactId>
-      <version>2.0.0</version>
+      <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
     </dependency>
 
     <dependency>
       <groupId>edu.tamu.weaver</groupId>
       <artifactId>core</artifactId>
-      <version>2.0.0</version>
+      <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
     </dependency>
 
     <dependency>

diff --git a/token/pom.xml b/token/pom.xml
@@ -12,7 +12,7 @@
   <parent>
     <groupId>edu.tamu.weaver</groupId>
     <artifactId>webservice-parent</artifactId>
-    <version>2.0.0</version>
+    <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
   </parent>
 
   <dependencies>

diff --git a/user/pom.xml b/user/pom.xml
@@ -12,7 +12,7 @@
   <parent>
     <groupId>edu.tamu.weaver</groupId>
     <artifactId>webservice-parent</artifactId>
-    <version>2.0.0</version>
+    <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
   </parent>
 
   <dependencies>
@@ -21,13 +21,13 @@
     <dependency>
       <groupId>edu.tamu.weaver</groupId>
       <artifactId>data</artifactId>
-      <version>2.0.0</version>
+      <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
     </dependency>
 
     <dependency>
       <groupId>edu.tamu.weaver</groupId>
       <artifactId>validation</artifactId>
-      <version>2.0.0</version>
+      <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
     </dependency>
 
   </dependencies>

diff --git a/validation/pom.xml b/validation/pom.xml
@@ -12,7 +12,7 @@
   <parent>
     <groupId>edu.tamu.weaver</groupId>
     <artifactId>webservice-parent</artifactId>
-    <version>2.0.0</version>
+    <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
   </parent>
 
   <dependencies>
@@ -21,7 +21,7 @@
     <dependency>
       <groupId>edu.tamu.weaver</groupId>
       <artifactId>data</artifactId>
-      <version>2.0.0</version>
+      <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
     </dependency>
 
     <dependency>

diff --git a/wro/pom.xml b/wro/pom.xml
@@ -13,7 +13,7 @@
   <parent>
     <groupId>edu.tamu.weaver</groupId>
     <artifactId>webservice-parent</artifactId>
-    <version>2.0.0</version>
+    <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
   </parent>
 
   <dependencies>
@@ -22,7 +22,7 @@
     <dependency>
       <groupId>edu.tamu.weaver</groupId>
       <artifactId>data</artifactId>
-      <version>2.0.0</version>
+      <version>2.x-MESSAGING-MODULE-SNAPSHOT</version>
     </dependency>
 
     <dependency>