1 package de.juplo.kafka;
3 import lombok.RequiredArgsConstructor;
4 import org.springframework.http.HttpStatus;
5 import org.springframework.http.ResponseEntity;
6 import org.springframework.web.bind.annotation.*;
10 import java.util.Optional;
14 @RequiredArgsConstructor
15 public class ApplicationController
17 private final AdderBusinessLogic adder;
20 @GetMapping("state/{user}")
21 public ResponseEntity<Long> state(@PathVariable String user)
25 .map(sum -> ResponseEntity.ok(sum))
26 .orElseGet(() -> ResponseEntity.notFound().build());
31 @ResponseStatus(HttpStatus.BAD_REQUEST)
32 public ErrorResponse illegalStateException(IllegalStateException e)
34 return new ErrorResponse(e.getMessage(), HttpStatus.BAD_REQUEST.value());