Make event-listener bootstrap more robust if nats is not available

thomasdarimont · May 4, 2024 · bdb2ea8 · bdb2ea8
1 parent 16bb873
commit bdb2ea8
Show file tree

Hide file tree

Showing 5 changed files with 62 additions and 9 deletions.
diff --git a/keycloak/extensions/pom.xml b/keycloak/extensions/pom.xml
@@ -307,6 +307,7 @@
 
             <plugin>
                 <artifactId>maven-assembly-plugin</artifactId>
+                <version>${maven-assembly-plugin.version}</version>
                 <configuration>
                     <descriptorRefs>
                         <descriptorRef>jar-with-dependencies</descriptorRef>

diff --git a/...ithub/thomasdarimont/keycloak/custom/eventpublishing/AcmeEventPublisherEventListener.java b/...ithub/thomasdarimont/keycloak/custom/eventpublishing/AcmeEventPublisherEventListener.java
@@ -65,7 +65,12 @@ public EventListenerProvider create(KeycloakSession session) {
         @Override
         public void init(Config.Scope config) {
             /* configure factory */
-            publisher = createNatsPublisher(config);
+            try {
+                publisher = createNatsPublisher(config);
+            } catch (Exception ex) {
+                log.warnf("Could not create nats publisher: %s", ex.getMessage());
+                publisher = new NoopPublisher();
+            }
         }
 
         private NatsEventPublisher createNatsPublisher(Config.Scope config) {

diff --git a/...in/java/com/github/thomasdarimont/keycloak/custom/eventpublishing/NatsEventPublisher.java b/...in/java/com/github/thomasdarimont/keycloak/custom/eventpublishing/NatsEventPublisher.java
@@ -53,7 +53,7 @@ public void init() {
         try {
             connection = Nats.connect(options);
         } catch (Exception e) {
-            log.warn("Could not connect to nats server", e);
+            throw new RuntimeException("Could not connect to nats server", e);
         }
     }
 

diff --git a/...rc/main/java/com/github/thomasdarimont/keycloak/custom/eventpublishing/NoopPublisher.java b/...rc/main/java/com/github/thomasdarimont/keycloak/custom/eventpublishing/NoopPublisher.java
@@ -0,0 +1,29 @@
+package com.github.thomasdarimont.keycloak.custom.eventpublishing;
+
+import lombok.extern.jbosslog.JBossLog;
+
+import java.util.Map;
+
+@JBossLog
+public class NoopPublisher implements EventPublisher{
+
+    @Override
+    public void publish(String topic, Object event) {
+        // NOOP
+    }
+
+    @Override
+    public Map<String, String> getOperationalInfo() {
+        return Map.of();
+    }
+
+    @Override
+    public void init() {
+        // NOOP
+    }
+
+    @Override
+    public void close() {
+        // NOOP
+    }
+}
diff --git a/pom.xml b/pom.xml
@@ -68,15 +68,33 @@
         <maven-failsafe-plugin.version>3.2.5</maven-failsafe-plugin.version>
         <maven-surefire-plugin.version>3.2.5</maven-surefire-plugin.version>
         <maven-jar-plugin.version>3.4.0</maven-jar-plugin.version>
+        <maven-assembly-plugin.version>3.6.0</maven-assembly-plugin.version>
+        <maven-compiler-plugin.version>3.12.1</maven-compiler-plugin.version>
+        <maven-clean-plugin.version>3.3.2</maven-clean-plugin.version>
+        <maven-resources-plugin.version>3.3.1</maven-resources-plugin.version>
     </properties>
 
     <build>
-        <plugins>
-            <plugin>
-                <groupId>org.apache.maven.plugins</groupId>
-                <artifactId>maven-compiler-plugin</artifactId>
-                <version>3.12.1</version>
-            </plugin>
-        </plugins>
+        <pluginManagement>
+            <plugins>
+                <plugin>
+                    <groupId>org.apache.maven.plugins</groupId>
+                    <artifactId>maven-compiler-plugin</artifactId>
+                    <version>${maven-compiler-plugin.version}</version>
+                </plugin>
+
+                <plugin>
+                    <groupId>org.apache.maven.plugins</groupId>
+                    <artifactId>maven-clean-plugin</artifactId>
+                    <version>${maven-clean-plugin.version}</version>
+                </plugin>
+
+                <plugin>
+                    <groupId>org.apache.maven.plugins</groupId>
+                    <artifactId>maven-resources-plugin</artifactId>
+                    <version>${maven-resources-plugin.version}</version>
+                </plugin>
+            </plugins>
+        </pluginManagement>
     </build>
 </project>