From: Kai Moritz Date: Sat, 13 Aug 2022 14:10:28 +0000 (+0200) Subject: GRÜN: Erwartungen implementiert X-Git-Tag: sumup-adder---lvm-2-tage~27 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=f83599b6aaefff62c286e2143bb2e8a81751e6fd;p=demos%2Fkafka%2Ftraining GRÜN: Erwartungen implementiert --- 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)