Integrated outbox-postage instead of the copy+pasted implementation

[demos/spring/data-jdbc] / src / main / java / de / juplo / kafka / outbox / OutboxListener.java

diff --git a/src/main/java/de/juplo/kafka/outbox/OutboxListener.java b/src/main/java/de/juplo/kafka/outbox/OutboxListener.java
deleted file mode 100644 (file)
index fa53469..0000000
--- a/src/main/java/de/juplo/kafka/outbox/OutboxListener.java
+++ /dev/null
@@ -1,34 +0,0 @@
-package de.juplo.kafka.outbox;
-
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import lombok.AllArgsConstructor;
-import org.springframework.stereotype.Component;
-import org.springframework.transaction.event.TransactionPhase;
-import org.springframework.transaction.event.TransactionalEventListener;
-
-
-@Component
-@AllArgsConstructor
-public class OutboxListener
-{
-  private final OutboxRepository repository;
-  private final ObjectMapper mapper;
-
-
-  @TransactionalEventListener(phase = TransactionPhase.BEFORE_COMMIT)
-  public void onUserEvent(OutboxEvent event)
-  {
-    try
-    {
-      repository.save(
-          event.getKey(),
-          mapper.writeValueAsString(event.getValue()),
-          event.getTime());
-    }
-    catch (JsonProcessingException e)
-    {
-      throw new RuntimeException(e);
-    }
-  }
-}