BAEL-9190: Sample appliction for Allegro Hermes integration (#18991)

Author: sazzer

messaging-modules/allegro-hermes/docker-compose.yml

@@ -0,0 +1,46 @@
+services:
+  zk:
+    image: "confluentinc/cp-zookeeper:7.9.4"
+    ports:
+      - "2181:2181"
+    user: root
+    environment:
+      ZOOKEEPER_CLIENT_PORT: 2181
+
+  kafka:
+    image: "confluentinc/cp-kafka:7.9.4"
+    ports:
+      - '9092:9092'
+    depends_on:
+      - zk
+    user: root
+    environment:
+      KAFKA_ZOOKEEPER_CONNECT: zk:2181
+      KAFKA_ADVERTISED_LISTENERS: DOCKER_INTERNAL_LISTENER://kafka:29092,DOCKER_EXTERNAL_LISTENER://localhost:9092
+      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: DOCKER_INTERNAL_LISTENER:PLAINTEXT,DOCKER_EXTERNAL_LISTENER:PLAINTEXT
+      KAFKA_INTER_BROKER_LISTENER_NAME: DOCKER_INTERNAL_LISTENER
+      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
+
+  frontend:
+    image: allegro/hermes-frontend:hermes-2.11.7
+    ports:
+      - "8080:8080"
+    depends_on:
+      - zk
+      - kafka
+
+  consumers:
+    image: allegro/hermes-consumers:hermes-2.11.7
+    ports:
+      - "8070:8070"
+    depends_on:
+      - zk
+      - kafka
+
+  management:
+    image: allegro/hermes-management:hermes-2.11.7
+    ports:
+      - "8090:8090"
+    depends_on:
+      - zk
+      - kafka

messaging-modules/allegro-hermes/pom.xml

@@ -0,0 +1,33 @@
+<?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>
+    <artifactId>allegro-hermes</artifactId>
+    <version>1.0-SNAPSHOT</version>
+    <name>allegro-hermes</name>
+
+    <parent>
+        <groupId>com.baeldung</groupId>
+        <artifactId>messaging-modules</artifactId>
+        <version>0.0.1-SNAPSHOT</version>
+    </parent>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>pl.allegro.tech.hermes</groupId>
+            <artifactId>hermes-client</artifactId>
+            <version>${hermes.version}</version>
+        </dependency>
+    </dependencies>
+
+    <properties>
+        <hermes.version>2.11.10</hermes.version>
+    </properties>
+
+</project>

messaging-modules/allegro-hermes/src/main/java/com/baeldung/messaging/hermes/HermesApplication.java

@@ -0,0 +1,11 @@
+package com.baeldung.messaging.hermes;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class HermesApplication {
+    public static void main(String[] args) {
+        SpringApplication.run(HermesApplication.class, args);
+    }
+}

messaging-modules/allegro-hermes/src/main/java/com/baeldung/messaging/hermes/PublishController.java

@@ -0,0 +1,44 @@
+package com.baeldung.messaging.hermes;
+
+import java.net.URI;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ExecutionException;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.client.RestClient;
+
+import pl.allegro.tech.hermes.client.HermesClient;
+import pl.allegro.tech.hermes.client.HermesClientBuilder;
+import pl.allegro.tech.hermes.client.HermesResponse;
+import pl.allegro.tech.hermes.client.HermesSender;
+import pl.allegro.tech.hermes.client.restclient.RestClientHermesSender;
+
+@RestController
+@RequestMapping("/publish")
+public class PublishController {
+    private static final Logger LOG = LoggerFactory.getLogger(PublishController.class);
+
+    @Value("${hermes.url}")
+    private String hermesUrl;
+
+    @PostMapping
+    public void publish() throws ExecutionException, InterruptedException {
+        HermesSender hermesSender = new RestClientHermesSender(RestClient.create());
+
+        HermesClient hermesClient = HermesClientBuilder.hermesClient(hermesSender)
+            .withURI(URI.create(hermesUrl))
+            .build();
+
+        CompletableFuture<HermesResponse> result =
+            hermesClient.publishJSON("com.baeldung.hermes.testing", "{\"hello\": 1}");
+
+        HermesResponse hermesResponse = result.join();
+
+        LOG.info("Result of publishing message: {}", hermesResponse);
+    }
+}

messaging-modules/allegro-hermes/src/main/java/com/baeldung/messaging/hermes/SubscribeController.java

@@ -0,0 +1,19 @@
+package com.baeldung.messaging.hermes;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/subscribe")
+public class SubscribeController {
+    private static final Logger LOG = LoggerFactory.getLogger(SubscribeController.class);
+
+    @PostMapping("/testing")
+    public void receive(@RequestBody String body) {
+        LOG.info("Received message: {}", body);
+    }
+}

messaging-modules/allegro-hermes/src/main/resources/application.properties

@@ -0,0 +1,3 @@
+server.port=7070
+
+hermes.url=http://localhost:8080

messaging-modules/pom.xml

@@ -28,6 +28,7 @@
         <module>postgres-notify</module>
         <module>ibm-mq</module>
         <module>dapr</module>
+        <module>allegro-hermes</module>
     </modules>
 
 </project>