Merge pull request #101 from reactive-commons/feature/disable-event-listener

Add option to disable event listener

Author: juancgalvis

async/async-rabbit-starter-eda/async-commons-rabbit-starter-eda.gradle

@@ -7,6 +7,7 @@ dependencies {
     api project(':async-rabbit')
     compileOnly 'org.springframework.boot:spring-boot-starter'
     compileOnly 'org.springframework.boot:spring-boot-starter-actuator'
+    implementation 'com.fasterxml.jackson.datatype:jackson-datatype-jsr310'
 
     annotationProcessor 'org.springframework.boot:spring-boot-configuration-processor'
 

async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/rabbit/config/EventListenersConfig.java

@@ -28,22 +28,24 @@ public ApplicationEventListener eventListener(MessageConverter messageConverter,
         AtomicReference<ApplicationEventListener> external = new AtomicReference<>();
         manager.forListener((domain, receiver) -> {
             AsyncProps asyncProps = asyncPropsDomain.getProps(domain);
-            final ApplicationEventListener listener = new ApplicationEventListener(receiver,
-                    asyncProps.getBrokerConfigProps().getEventsQueue(),
-                    asyncProps.getBrokerConfigProps().getDomainEventsExchangeName(),
-                    handlers.get(domain),
-                    messageConverter, asyncProps.getWithDLQRetry(),
-                    asyncProps.getCreateTopology(),
-                    asyncProps.getMaxRetries(),
-                    asyncProps.getRetryDelay(),
-                    asyncProps.getDomain().getEvents().getMaxLengthBytes(),
-                    manager.getDiscardNotifier(domain),
-                    errorReporter,
-                    asyncProps.getAppName());
-            if (DEFAULT_DOMAIN.equals(domain)) {
-                external.set(listener);
+            if (!asyncProps.getDomain().isIgnoreThisListener()) {
+                final ApplicationEventListener listener = new ApplicationEventListener(receiver,
+                        asyncProps.getBrokerConfigProps().getEventsQueue(),
+                        asyncProps.getBrokerConfigProps().getDomainEventsExchangeName(),
+                        handlers.get(domain),
+                        messageConverter, asyncProps.getWithDLQRetry(),
+                        asyncProps.getCreateTopology(),
+                        asyncProps.getMaxRetries(),
+                        asyncProps.getRetryDelay(),
+                        asyncProps.getDomain().getEvents().getMaxLengthBytes(),
+                        manager.getDiscardNotifier(domain),
+                        errorReporter,
+                        asyncProps.getAppName());
+                if (DEFAULT_DOMAIN.equals(domain)) {
+                    external.set(listener);
+                }
+                listener.startListener();
             }
-            listener.startListener();
         });
 
         return external.get();

async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/rabbit/config/props/AsyncPropsDomain.java

@@ -1,5 +1,7 @@
 package org.reactivecommons.async.rabbit.config.props;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
 import lombok.Getter;
 import lombok.Setter;
 import org.reactivecommons.async.rabbit.config.RabbitProperties;
@@ -20,6 +22,8 @@ public AsyncPropsDomain(@Value("${spring.application.name}") String defaultAppNa
                             SecretFiller secretFiller) {
         super(configured);
         this.computeIfAbsent(DEFAULT_DOMAIN, k -> new AsyncProps());
+        ObjectMapper mapper = new ObjectMapper();
+        mapper.registerModule(new JavaTimeModule());
         super.forEach((key, value) -> { // To ensure that each domain has an appName
             if (value.getAppName() == null) {
                 if (defaultAppName == null || defaultAppName.isEmpty()) {
@@ -35,7 +39,7 @@ public AsyncPropsDomain(@Value("${spring.application.name}") String defaultAppNa
                             " RabbitProperties properties found, please use withDefaultRabbitProperties or define the" +
                             "default " + key + " domain with properties explicitly");
                 }
-                value.setConnectionProperties(defaultRabbitProperties);
+                value.setConnectionProperties(mapper.convertValue(defaultRabbitProperties, RabbitProperties.class));
             }
             if (value.getBrokerConfigProps() == null) {
                 value.setBrokerConfigProps(new BrokerConfigProps(value));

async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/rabbit/config/props/DomainProps.java

@@ -17,5 +17,5 @@ public class DomainProps {
     @NestedConfigurationProperty
     @Builder.Default
     private EventsProps events = new EventsProps();
-
+    private boolean ignoreThisListener = false;
 }

gradle.properties

@@ -1,4 +1,4 @@
-version=2.2.2
+version=2.2.3
 springBootVersion=3.2.5
 reactorRabbitVersion=1.5.5
 cloudEventsVersion=3.0.0