diff --git a/async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/rabbit/config/ConnectionManager.java b/async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/rabbit/config/ConnectionManager.java
index 123b7915..a2ac9760 100644
--- a/async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/rabbit/config/ConnectionManager.java
+++ b/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,
diff --git a/async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/rabbit/config/RabbitMqConfig.java b/async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/rabbit/config/RabbitMqConfig.java
index 83f5601d..ef282676 100644
--- a/async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/rabbit/config/RabbitMqConfig.java
+++ b/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;
     }