WIP

diff --git a/transfer/pom.xml b/transfer/pom.xml
index a565231..f1305cf 100644 (file)
--- a/transfer/pom.xml
+++ b/transfer/pom.xml
@@ -49,6 +49,10 @@
                        <artifactId>kafka-streams-avro-serde</artifactId>
                        <version>${confluent.version}</version>
                </dependency>
+               <dependency>
+                       <groupId>jakarta.validation</groupId>
+                       <artifactId>jakarta.validation-api</artifactId>
+               </dependency>
                <dependency>
                        <groupId>org.projectlombok</groupId>
                        <artifactId>lombok</artifactId>

diff --git a/transfer/src/main/java/de/juplo/kafka/payment/transfer/TransferService.java b/transfer/src/main/java/de/juplo/kafka/payment/transfer/TransferService.java
index a99634e..15550af 100644 (file)
--- a/transfer/src/main/java/de/juplo/kafka/payment/transfer/TransferService.java
+++ b/transfer/src/main/java/de/juplo/kafka/payment/transfer/TransferService.java
@@ -17,6 +17,8 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RestController;
 import org.springframework.web.context.request.async.DeferredResult;
 
+import javax.validation.Valid;
+
 
 @RestController
 public class TransferService
@@ -42,7 +44,7 @@ public class TransferService
       path = "/orders",
       consumes = MediaType.APPLICATION_JSON_UTF8_VALUE,
       produces = MediaType.TEXT_PLAIN_VALUE)
-  public DeferredResult<ResponseEntity<?>> placeOrder(@Valid @RequestBody OrderBean order)
+  public DeferredResult<ResponseEntity<?>> placeOrder(@Valid @RequestBody Transfer order)
   {
     DeferredResult<ResponseEntity<?>> result = new DeferredResult<>();