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

   1 package de.juplo.kafka;
   2
   3
   4 import org.springframework.stereotype.Component;
   5
   6 import java.util.HashMap;
   7 import java.util.Map;
   8 import java.util.Optional;
   9
  10
  11 @Component
  12 public class AdderBusinessLogic
  13 {
  14   private final Map<String, AdderResult> state;
  15
  16
  17   public AdderBusinessLogic()
  18   {
  19     this(new HashMap<>());
  20   }
  21
  22   public AdderBusinessLogic(Map<String, AdderResult> state)
  23   {
  24     this.state = state;
  25   }
  26
  27
  28   public synchronized Optional<Long> getSum(String user)
  29   {
  30     return Optional.ofNullable(state.get(user)).map(result -> result.sum);
  31   }
  32
  33   public synchronized void addToSum(String user, Integer value)
  34   {
  35     if (value == null || value < 1)
  36       throw new IllegalArgumentException("Not a positive number: " + value);
  37
  38     long sum =
  39         Optional
  40             .ofNullable(state.get(user))
  41             .map(result -> result.sum)
  42             .orElse(0l);
  43     state.put(user, new AdderResult(value, sum + value));
  44   }
  45
  46   public synchronized AdderResult calculate(String user)
  47   {
  48     if (!state.containsKey(user))
  49       throw new IllegalStateException("No sumation for " + user + " in progress");
  50
  51     return state.remove(user);
  52   }
  53 }