From 0b6377951bbeeb2443415bc2aa9c68988ee4c5af Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sat, 13 Aug 2022 16:10:28 +0200 Subject: [PATCH] =?utf8?q?GR=C3=9CN:=20Erwartungen=20implementiert?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- src/main/java/de/juplo/kafka/SumBusinessLogic.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/src/main/java/de/juplo/kafka/SumBusinessLogic.java b/src/main/java/de/juplo/kafka/SumBusinessLogic.java index f7bf09f..74696a4 100644 --- a/src/main/java/de/juplo/kafka/SumBusinessLogic.java +++ b/src/main/java/de/juplo/kafka/SumBusinessLogic.java @@ -36,6 +36,13 @@ public class SumBusinessLogic public synchronized void addToSum(String user, Integer value) { + if (!state.containsKey(user)) + throw new IllegalStateException("No sumation for " + user + " in progress"); + if (value == null || value < 1) + throw new IllegalArgumentException("Not a positive number: " + value); + + long result = state.get(user) + value; + state.put(user, result); } public synchronized Long endSum(String user) -- 2.20.1