Introduced different Events for the creation and the state-changes

[demos/kafka/demos-kafka-payment-system-transfer] / src / main / java / de / juplo / kafka / payment / transfer / TransferServiceApplication.java

diff --git a/src/main/java/de/juplo/kafka/payment/transfer/TransferServiceApplication.java b/src/main/java/de/juplo/kafka/payment/transfer/TransferServiceApplication.java
index 02842e5..58a3af2 100644 (file)
--- a/src/main/java/de/juplo/kafka/payment/transfer/TransferServiceApplication.java
+++ b/src/main/java/de/juplo/kafka/payment/transfer/TransferServiceApplication.java
@@ -67,7 +67,14 @@ public class TransferServiceApplication
       TransferService transferService)
   {
     TransferConsumer transferConsumer =
-        new TransferConsumer(properties.topic, consumer, executorService, mapper, transferService);
+        new TransferConsumer(
+            properties.topic,
+            consumer,
+            executorService,
+            mapper,
+            transferService,
+            transferService,
+            transferService);
     transferConsumer.start();
     return transferConsumer;
   }