WIP

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

diff --git a/transfer/src/main/java/de/juplo/kafka/payment/transfer/domain/TransferService.java b/transfer/src/main/java/de/juplo/kafka/payment/transfer/domain/TransferService.java
index 34ef29c..6545e29 100644 (file)
--- a/transfer/src/main/java/de/juplo/kafka/payment/transfer/domain/TransferService.java
+++ b/transfer/src/main/java/de/juplo/kafka/payment/transfer/domain/TransferService.java
@@ -21,19 +21,26 @@ public class TransferService
   private final ObjectMapper mapper;
   private final String topic;
 
-  public void initiate(Transfer transfer)
+  public synchronized void initiate(Transfer transfer)
   {
     repository
         .get(transfer.getId())
         .ifPresentOrElse(
             stored ->
             {
-
+              switch (stored.getState())
+              {
+                case FAILED:
+              }
             },
             () ->
             {
-
             });
+  }
+
+
+  private void create(Transfer transfer)
+  {
     try
     {
       ProducerRecord<UUID, String> record =