1 package de.trion.kafka.outbox;
3 import org.slf4j.Logger;
4 import org.slf4j.LoggerFactory;
5 import org.springframework.http.HttpStatus;
6 import org.springframework.http.ResponseEntity;
7 import org.springframework.web.bind.annotation.*;
8 import org.springframework.web.context.request.async.DeferredResult;
11 public class OutboxController {
13 private static final Logger LOG = LoggerFactory.getLogger(OutboxController.class);
16 private final OutboxService service;
19 public OutboxController(OutboxService service) {
20 this.service = service;
24 @PostMapping("/create")
25 public ResponseEntity<Void> getVorgang(@RequestBody String user) {