From f83599b6aaefff62c286e2143bb2e8a81751e6fd 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/AdderBusinessLogic.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/src/main/java/de/juplo/kafka/AdderBusinessLogic.java b/src/main/java/de/juplo/kafka/AdderBusinessLogic.java index bd89871..503fa88 100644 --- a/src/main/java/de/juplo/kafka/AdderBusinessLogic.java +++ b/src/main/java/de/juplo/kafka/AdderBusinessLogic.java @@ -37,6 +37,13 @@ public class AdderBusinessLogic 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