WIP

[demos/kafka/demos-kafka-payment-system-transfer] / transfer / src / main / java / de / juplo / kafka / payment / transfer / controller / TransferController.java

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 (file)
--- 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();
   }
 }