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 f5d41cb..d708826 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
@@ -7,10 +7,8 @@ import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerRecord;
-import org.springframework.http.ResponseEntity;
 
-import java.net.URI;
-import java.util.UUID;
+import java.util.Optional;
 
 import static de.juplo.kafka.payment.transfer.domain.Transfer.State.*;
 
@@ -47,8 +45,9 @@ public class TransferService
             },
             () ->
             {
-              repository.store(transfer);
               send(transfer);
+              transfer.setState(SENT);
+              repository.store(transfer);
             });
   }
 
@@ -82,4 +81,9 @@ public class TransferService
       throw new RuntimeException("Could not convert " + transfer, e);
     }
   }
+
+  public Optional<Transfer> get(Long id)
+  {
+    return repository.get(id);
+  }
 }