juplo.de Git - demos/kafka/training/blob - src/main/java/de/juplo/kafka/AdderBusinessLogic.java

   1 package de.juplo.kafka;
   2
   3
   4 import java.util.HashMap;
   5 import java.util.Map;
   6 import java.util.Optional;
   7
   8
   9 public class AdderBusinessLogic
  10 {
  11   private final Map<String, Long> state;
  12
  13
  14   public AdderBusinessLogic()
  15   {
  16     this(new HashMap<>());
  17   }
  18
  19   public AdderBusinessLogic(Map<String, Long> state)
  20   {
  21     this.state = state;
  22   }
  23
  24
  25   public synchronized void startSum(String user)
  26   {
  27     if (state.containsKey(user))
  28       throw new IllegalStateException("Sumation for " + user + " already in progress, state: " + state.get(user));
  29
  30     state.put(user, 0l);
  31   }
  32
  33   public synchronized Optional<Long> getSum(String user)
  34   {
  35     return Optional.ofNullable(state.get(user));
  36   }
  37
  38   public synchronized void addToSum(String user, Integer value)
  39   {
  40   }
  41
  42   public synchronized Long endSum(String user)
  43   {
  44     if (!state.containsKey(user))
  45       throw new IllegalStateException("No sumation for " + user + " in progress");
  46
  47     return state.get(user);
  48   }
  49 }