X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;ds=sidebyside;f=transfer%2Fsrc%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fpayment%2Ftransfer%2Fcontroller%2FTransferController.java;h=d8dcc837392609e83afb7f485eb7d709ffd58ef7;hb=c3d8ff110b30df7013d9b9c8440c3591766ba072;hp=12547efcd3aafec0983d420b9fd72bf4943f6dc0;hpb=5bffe60126c5fa74bff59c91dfbd722d291b1c93;p=demos%2Fkafka%2Fdemos-kafka-payment-system-transfer

diff --git a/transfer/src/main/java/de/juplo/kafka/payment/transfer/controller/TransferController.java b/transfer/src/main/java/de/juplo/kafka/payment/transfer/controller/TransferController.java
index 12547ef..d8dcc83 100644
--- a/transfer/src/main/java/de/juplo/kafka/payment/transfer/controller/TransferController.java
+++ b/transfer/src/main/java/de/juplo/kafka/payment/transfer/controller/TransferController.java
@@ -31,7 +31,17 @@ public class TransferController
       produces = MediaType.APPLICATION_JSON_VALUE)
   public ResponseEntity<?> transfer(@Valid @RequestBody TransferRequest transferRequest)
   {
-    service.initiate(transferRequest);
+    Transfer transfer =
+        Transfer
+            .builder()
+            .id(transferRequest.getId())
+            .payer(transferRequest.getPayer())
+            .payee(transferRequest.getPayee())
+            .amount(transferRequest.getAmount())
+            .build();
+
+    service.initiate(transfer);
+
     return ResponseEntity.created(URI.create(PATH + transferRequest.getId())).build();
   }
 }