Benennung vereinheitlicht und projektunabhängig gemacht

[demos/kafka/training] / src / main / java / de / juplo / kafka / DriverController.java

diff --git a/src/main/java/de/juplo/kafka/DriverController.java b/src/main/java/de/juplo/kafka/DriverController.java
index 0870f19..d389271 100644 (file)
--- a/src/main/java/de/juplo/kafka/DriverController.java
+++ b/src/main/java/de/juplo/kafka/DriverController.java
@@ -16,7 +16,7 @@ import java.util.stream.Collectors;
 public class DriverController
 {
   private final EndlessConsumer consumer;
-  private final AdderRecordHandler adderRecordHandler;
+  private final ApplicationRecordHandler recordHandler;
 
 
   @PostMapping("start")
@@ -36,7 +36,7 @@ public class DriverController
   public Map<Integer, Map<String, Long>> state()
   {
     return
-        adderRecordHandler
+        recordHandler
             .getState()
             .entrySet()
             .stream()
@@ -48,9 +48,9 @@ public class DriverController
   @GetMapping("state/{user}")
   public ResponseEntity<Long> seen(@PathVariable String user)
   {
-    for (AdderBusinessLogic adderBusinessLogic : adderRecordHandler.getState().values())
+    for (AdderBusinessLogic adder : recordHandler.getState().values())
     {
-      Optional<Long> sum = adderBusinessLogic.getSum(user);
+      Optional<Long> sum = adder.getSum(user);
       if (sum.isPresent())
         return ResponseEntity.ok(sum.get());
     }