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