X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=transfer%2Fsrc%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fpayment%2Ftransfer%2Fdomain%2FTransferService.java;h=d70882640c934f5d7ea8122441ff3a05c6bbe251;hb=abea9b5c5ff90b2db1ab7bd577d644c05a4dd37f;hp=f5d41cb0f2031c9207190d3cbd5b9a133df763ff;hpb=e99b64cc787c34c3fec438cf67434b8ea0d8cd43;p=demos%2Fkafka%2Fdemos-kafka-payment-system-setup

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
--- 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);
+  }
 }