fix(notifier): Set the discard notifier with domain connection properties

fix(notifier): Set the discard notifier with domain connection properties

Author: juancgalvis

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

@@ -32,8 +32,8 @@ public void forListener(BiConsumer<String, ReactiveMessageListener> consumer) {
         connections.forEach((key, conn) -> consumer.accept(key, conn.getListener()));
     }
 
-    public void setDiscardNotifierForAll(DiscardNotifier discardNotifier) {
-        connections.forEach((key, conn) -> conn.setDiscardNotifier(discardNotifier));
+    public void setDiscardNotifier(String domain, DiscardNotifier discardNotifier) {
+        getChecked(domain).setDiscardNotifier(discardNotifier);
     }
 
     public ConnectionManager addDomain(String domain, ReactiveMessageListener listener, ReactiveMessageSender sender,

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

@@ -79,12 +79,13 @@ public ConnectionManager buildConnectionManager(AsyncPropsDomain props, MessageC
             ReactiveMessageSender sender = createMessageSender(provider, properties, converter);
             ReactiveMessageListener listener = createMessageListener(provider, properties);
             connectionManager.addDomain(domain, listener, sender, provider);
+            
+            ReactiveMessageSender appDomainSender = connectionManager.getSender(domain);
+            DomainEventBus appDomainEventBus = new RabbitDomainEventBus(appDomainSender, props.getProps(domain)
+                    .getBrokerConfigProps().getDomainEventsExchangeName(), brokerConfig);
+            DiscardNotifier notifier = new RabbitDiscardNotifier(appDomainEventBus, objectMapperSupplier.get());
+            connectionManager.setDiscardNotifier(domain, notifier);
         });
-        ReactiveMessageSender appDomainSender = connectionManager.getSender(DEFAULT_DOMAIN);
-        DomainEventBus appDomainEventBus = new RabbitDomainEventBus(appDomainSender, props.getProps(DEFAULT_DOMAIN)
-                .getBrokerConfigProps().getDomainEventsExchangeName(), brokerConfig);
-        DiscardNotifier notifier = new RabbitDiscardNotifier(appDomainEventBus, objectMapperSupplier.get());
-        connectionManager.setDiscardNotifierForAll(notifier);
         return connectionManager;
     }