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

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