X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FSumBusinessLogic.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FSumBusinessLogic.java;h=cea533fa4db597f18b8156d5b4f82ff5d252b6e0;hb=e9f30aead5b4456b51944436961891d9a4962612;hp=0000000000000000000000000000000000000000;hpb=53c63296c53bfe30bd50eb52a6e455beb6792015;p=demos%2Fkafka%2Ftraining diff --git a/src/main/java/de/juplo/kafka/SumBusinessLogic.java b/src/main/java/de/juplo/kafka/SumBusinessLogic.java new file mode 100644 index 0000000..cea533f --- /dev/null +++ b/src/main/java/de/juplo/kafka/SumBusinessLogic.java @@ -0,0 +1,16 @@ +package de.juplo.kafka; + +import java.util.HashMap; +import java.util.Map; + + +public class SumBusinessLogic +{ + public SumBusinessLogic() + { + } + + public synchronized void startSum(String user) + { + } +}