X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FDriverController.java;h=63f015d42cfb6ebb5de00b980c0e88dc98f97071;hb=7c0368363c3e5dbb7eb2a08f343187a93f050617;hp=0870f19de5dcdda626eb790a39106a4af7f22d2f;hpb=5b4b7acf7b6a02e0e5c779257d3f5996366625e6;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/DriverController.java b/src/main/java/de/juplo/kafka/DriverController.java
index 0870f19..63f015d 100644
--- 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")
@@ -33,10 +33,10 @@ public class DriverController
 
 
   @GetMapping("state")
-  public Map<Integer, Map<String, Long>> state()
+  public Map<Integer, Map<String, AdderResult>> 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());
     }