X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=transfer%2Fsrc%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fpayment%2Ftransfer%2FTransferService.java;h=15550af3e623e6755d103f69b3b437b257ac8068;hb=e337851962a0ef2155b17bd6789f4eac9583d917;hp=9da09a91d3967db54c49f06ee9d38638a13e33dc;hpb=178ce6ffc044415eb00f250aed2f9b1999bd47d1;p=demos%2Fkafka%2Fdemos-kafka-payment-system-transfer

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 9da09a9..15550af 100644
--- a/transfer/src/main/java/de/juplo/kafka/payment/transfer/TransferService.java
+++ b/transfer/src/main/java/de/juplo/kafka/payment/transfer/TransferService.java
@@ -1,11 +1,11 @@
 package de.juplo.kafka.payment.transfer;
 
 
-import de.trion.microservices.avro.Order;
-import de.trion.microservices.avro.OrderState;
 import java.net.URI;
 import java.util.UUID;
-import javax.validation.Valid;
+
+import de.juplo.kafka.payment.avro.Order;
+import de.juplo.kafka.payment.avro.OrderState;
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.slf4j.Logger;
@@ -17,13 +17,15 @@ 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
 {
   private final static Logger LOG = LoggerFactory.getLogger(TransferService.class);
 
-  private final KafkaProducer<UUID,Order> producer;
+  private final KafkaProducer<UUID, Order> producer;
   private final String topic;
   private final String path;
 
@@ -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<>();