X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Ftrion%2Fkafka%2Foutbox%2FOutboxController.java;h=e1f89190a81c61810d61b316c3fcce5474c62735;hb=5dea0011f01dac3a691a30bb0cd9495252f67d8b;hp=f1119f2edf83e2cedbf577db2b2961a42580903e;hpb=57f90dfdd0b944c0ee82fe20ebe554f1f874fe57;p=demos%2Fkafka%2Foutbox diff --git a/src/main/java/de/trion/kafka/outbox/OutboxController.java b/src/main/java/de/trion/kafka/outbox/OutboxController.java index f1119f2..e1f8919 100644 --- a/src/main/java/de/trion/kafka/outbox/OutboxController.java +++ b/src/main/java/de/trion/kafka/outbox/OutboxController.java @@ -5,6 +5,7 @@ import org.slf4j.LoggerFactory; import org.springframework.http.ResponseEntity; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.bind.annotation.*; +import org.springframework.web.servlet.support.ServletUriComponentsBuilder; import org.springframework.web.util.UriComponents; import org.springframework.web.util.UriComponentsBuilder; @@ -26,15 +27,19 @@ public class OutboxController { } - @PostMapping() + @PostMapping public ResponseEntity getVorgang( - UriComponentsBuilder builder, + ServletUriComponentsBuilder builder, @RequestBody String username) { String cleaned = username.trim().toLowerCase(); User user = new User(cleaned, LocalDateTime.now(), false); repository.save(user); // TODO: Not-Unique Fehler auslösen - UriComponents uri = builder.path("{username}").buildAndExpand(cleaned); + UriComponents uri = + builder + .fromCurrentRequest() + .path("{username}") + .buildAndExpand(cleaned); return ResponseEntity.created(uri.toUri()).build(); } }