finis activemq-spring-stomp

Author: Maksim Kostromin

activemq-spring-stomp/build.gradle

@@ -37,3 +37,11 @@ gradle.includedBuilds.each { build ->
     finalizedBy composeDown
   }
 }
+
+["dockerUp", "dockerDown"].each { taskName ->
+  gradle.includedBuilds.findAll({ it.name == "docker" }).each { build ->
+    tasks.create(taskName) { task ->
+      dependsOn gradle.includedBuild(build.name).task(":$taskName")
+    }
+  }
+}

activemq-spring-stomp/client-frontend-app/src/main/java/daggerok/domain/MessageRestRepository.java

@@ -12,22 +12,17 @@ services:
       - "61614:61614" # ws
       - "61616:61616" # jms
     networks: [backing-services]
-    volumes: ["activemq-data:/opt/activemq/conf", "activemq-data:/data/activemq", "activemq-data:/var/log/activemq"]
+    volumes:
+      - "activemq-data:/opt/activemq/conf"
+      - "activemq-data:/data/activemq"
+      - "activemq-data:/var/log/activemq"
     environment:
+      ACTIVEMQ_MIN_MEMORY: 512
+      ACTIVEMQ_MAX_MEMORY: 2048
+      ACTIVEMQ_ENABLED_SCHEDULER: "true"
       ACTIVEMQ_REMOVE_DEFAULT_ACCOUNT: "true"
       ACTIVEMQ_ADMIN_LOGIN: admin
       ACTIVEMQ_ADMIN_PASSWORD: password
-      ACTIVEMQ_WRITE_LOGIN: write
-      ACTIVEMQ_WRITE_PASSWORD: password
-      ACTIVEMQ_READ_LOGIN: read
-      ACTIVEMQ_READ_PASSWORD: password
-      ACTIVEMQ_JMX_LOGIN: jmx
-      ACTIVEMQ_JMX_PASSWORD: password
-      ACTIVEMQ_STATIC_TOPICS: static-topic-1;static-topic-2
-      ACTIVEMQ_STATIC_QUEUES: static-queue-1;static-queue-2
-      ACTIVEMQ_ENABLED_SCHEDULER: "true"
-      ACTIVEMQ_MIN_MEMORY: 512
-      ACTIVEMQ_MAX_MEMORY: 2048
 
   postgres:
     image: healthcheck/postgres:alpine

activemq-spring-stomp/client-frontend-app/src/main/java/daggerok/messaging/JmsConfig.java

@@ -0,0 +1,17 @@
+plugins {
+  id "base"
+  id "com.avast.gradle.docker-compose" version "0.3.21"
+}
+
+dockerCompose {
+  useComposeFiles = ["$projectDir/docker-compose.yml"]
+  captureContainersOutput = true
+  stopContainers = true
+  removeContainers = true
+  removeImages = "Local"
+  removeVolumes = true
+  projectName = "$rootProject.name"
+}
+
+task dockerUp(dependsOn: composeUp)
+task dockerDown(dependsOn: composeDown)

activemq-spring-stomp/client-frontend-app/src/main/java/daggerok/messaging/StompConfig.java

@@ -0,0 +1,43 @@
+version: "2.1"
+
+services:
+
+  activemq:
+    image: webcenter/activemq:5.14.3
+    ports:
+      - "1883:1883"   # mqtt
+      - "5672:5672"   # amqp
+      - "8161:8161"   # ui
+      - "61613:61613" # stomp
+      - "61614:61614" # ws
+      - "61616:61616" # jms
+    networks: [backing-services]
+    volumes:
+      - "activemq-data:/opt/activemq/conf"
+      - "activemq-data:/data/activemq"
+      - "activemq-data:/var/log/activemq"
+    environment:
+      ACTIVEMQ_MIN_MEMORY: 512
+      ACTIVEMQ_MAX_MEMORY: 2048
+      ACTIVEMQ_ENABLED_SCHEDULER: "true"
+      ACTIVEMQ_REMOVE_DEFAULT_ACCOUNT: "true"
+      ACTIVEMQ_ADMIN_LOGIN: admin
+      ACTIVEMQ_ADMIN_PASSWORD: password
+
+  postgres:
+    image: healthcheck/postgres:alpine
+    ports: ["5432:5432"]
+    networks: [backing-services]
+    volumes: ["postgres-data:/var/lib/postgresql/data"]
+    environment:
+      POSTGRES_DB: db
+      POSTGRES_USER: user
+      POSTGRES_PASSWORD: password
+
+volumes:
+  activemq-data: {}
+  postgres-data: {}
+
+networks:
+  backing-services:
+    driver: bridge

activemq-spring-stomp/client-frontend-app/src/main/java/daggerok/rest/MessageResource.java

@@ -1,6 +1,3 @@
-import java.nio.file.Files
-import java.nio.file.Paths
-
 buildscript {
   ext {
     springBootVersion = "1.5.7.RELEASE"
@@ -10,7 +7,7 @@ buildscript {
 
 plugins {
   id "java"
-  id "com.moowork.node" version "1.2.0"
+  id "idea"
   id "cn.bestwu.propdeps" version "0.0.10"
   id "cn.bestwu.propdeps-idea" version "0.0.10"
   id "cn.bestwu.propdeps-maven" version "0.0.10"
@@ -49,13 +46,6 @@ dependencies {
   compile("com.querydsl:querydsl-jpa")
 
   compile("org.projectlombok:lombok")
-//  compile("org.webjars:EventSource:0.0.9")
-//  compile("org.webjars.npm:eventsource:0.1.6")
-
-  compile "org.webjars:webjars-locator",
-      "org.webjars:sockjs-client:1.0.2",
-      "org.webjars:stomp-websocket:2.3.3",
-      "org.webjars.npm:types__whatwg-fetch:0.0.33"
 
   optional("org.springframework.boot:spring-boot-configuration-processor")
 
@@ -65,28 +55,6 @@ dependencies {
   testCompile("org.springframework.boot:spring-boot-starter-test")
 }
 
-clean {
-  delete "$projectDir/src/main/js/node_modules"
-  delete "$projectDir/src/main/js/build"
-  delete "$projectDir/node_modules"
-  delete "$buildDir"
-}
-
-// node plugin: https://github.com/srs/gradle-node-plugin/blob/master/docs/node.md
-node {
-  version = "6.9.2"
-  npmVersion = "3.10.9"
-  distBaseUrl = "https://nodejs.org/dist"
-  download = true
-  workDir = file("$buildDir/nodejs")
-  npmWorkDir = file("$buildDir/npm")
-  yarnWorkDir = file("$buildDir/yarn")
-  nodeModulesDir = file("$projectDir/src/main/js")
-}
-
-processResources { dependsOn npm_run_build }
-[build, test, assemble].each { it.dependsOn npm_i }
-
 // spring dependency management plugin
 dependencyManagement {
   imports {
@@ -107,3 +75,7 @@ sourceSets {
   main
   test
 }
+
+clean {
+  delete "$projectDir/out"
+}

activemq-spring-stomp/client-frontend-app/src/main/java/daggerok/rest/StompResource.java

@@ -1,6 +1,6 @@
-#Tue Oct 17 13:28:41 EEST 2017
+#Tue Oct 17 18:23:01 EEST 2017
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-4.2.1-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-4.2.1-all.zip

activemq-spring-stomp/docker-compose.yml

@@ -4,9 +4,9 @@
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
 @SpringBootApplication
-public class Application {
+public class MessagingBackend {
 
   public static void main(String[] args) {
-    SpringApplication.run(Application.class, args);
+    SpringApplication.run(MessagingBackend.class, args);
   }
 }

activemq-spring-stomp/docker/build.gradle

@@ -3,6 +3,8 @@
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.querydsl.QueryDslPredicateExecutor;
 import org.springframework.stereotype.Repository;
+import org.springframework.web.bind.annotation.CrossOrigin;
 
+@CrossOrigin
 @Repository
 public interface MessageRestRepository extends JpaRepository<Message, Long>, QueryDslPredicateExecutor<Message> {}

activemq-spring-stomp/docker/docker-compose.yml

@@ -1,6 +1,6 @@
 package daggerok.messaging;
 
-import daggerok.Application;
+import daggerok.MessagingBackend;
 import daggerok.domain.Message;
 import daggerok.props.MessageQueueProperties;
 import lombok.RequiredArgsConstructor;
@@ -39,7 +39,7 @@ public ConnectionFactory connectionFactory() {
   public DefaultJmsListenerContainerFactory jmsListenerContainerFactory() {
     val factory = new DefaultJmsListenerContainerFactory();
     factory.setConnectionFactory(connectionFactory());
-    factory.setClientId(Application.class.getName());
+    factory.setClientId(MessagingBackend.class.getName());
     factory.setConcurrency("2-10");
     return factory;
   }

activemq-spring-stomp/client-frontend-app/settings.gradle renamed to activemq-spring-stomp/docker/settings.gradle

@@ -27,7 +27,7 @@ public class MessageConsumer {
   @JmsListener(destination = "jms.topic.messages")
   public void dot(final Message message) {
     val result = messageRepository.save(message);
-    log.info("saving: {}", result);
+    log.debug("saving: {}", result);
     brokerMessagingTemplate.convertAndSend("/topic/messages", objectMapper.writeValueAsString(result));
   }
 }

activemq-spring-stomp/client-frontend-app/README.md renamed to activemq-spring-stomp/messaging-backend/README.md

@@ -14,7 +14,7 @@ public class MessageProducer {
   final JmsTemplate jmsTemplate;
 
   public void send(final Message message) {
-    log.info("before save {}", message);
+    log.debug("before save {}", message);
     jmsTemplate.convertAndSend("jms.topic.messages", message);
   }
 }