From b9a482c8228e0b9197d7cb0c3f6b8849e5cd66da Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Mon, 15 Aug 2022 19:12:12 +0200 Subject: [PATCH] =?utf8?q?GR=C3=9CN:=20Neue=20Erwartungen=20umgesetzt?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- src/main/java/de/juplo/kafka/AdderBusinessLogic.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/main/java/de/juplo/kafka/AdderBusinessLogic.java b/src/main/java/de/juplo/kafka/AdderBusinessLogic.java index ecd9590..cbd500d 100644 --- a/src/main/java/de/juplo/kafka/AdderBusinessLogic.java +++ b/src/main/java/de/juplo/kafka/AdderBusinessLogic.java @@ -29,13 +29,14 @@ 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); + long sum = + Optional + .ofNullable(state.get(user)) + .orElse(0l); + state.put(user, sum + value); } public synchronized Long calculate(String user) -- 2.20.1