From 5eea6ee38fce9021fbbf8eb70cb3a092d607e843 Mon Sep 17 00:00:00 2001
From: Pol Pinol Castuera <pol.pinol@mongodb.com>
Date: Mon, 26 May 2025 21:49:16 +0200
Subject: [PATCH] Fix publish event

---
 .../event_publishers/PubsubEventPublisher.java             | 7 +------
 1 file changed, 1 insertion(+), 6 deletions(-)

diff --git a/src/main/java/io/autoinvestor/infrastructure/event_publishers/PubsubEventPublisher.java b/src/main/java/io/autoinvestor/infrastructure/event_publishers/PubsubEventPublisher.java
index c88a53f..c44f765 100644
--- a/src/main/java/io/autoinvestor/infrastructure/event_publishers/PubsubEventPublisher.java
+++ b/src/main/java/io/autoinvestor/infrastructure/event_publishers/PubsubEventPublisher.java
@@ -45,12 +45,7 @@ public void publish(List<Event<?>> events) {
 
         events.stream()
                 .map(mapper::toMessage)
-                .forEach(msg -> {
-                    publisher.publish(msg).addListener(
-                            () -> log.debug("Published msgId={}", msg.getMessageId()),
-                            Runnable::run
-                    );
-                });
+                .forEach(publisher::publish);
     }
 
     @PreDestroy