1 package de.juplo.kafka;
3 import lombok.RequiredArgsConstructor;
4 import lombok.extern.slf4j.Slf4j;
7 @RequiredArgsConstructor
9 public class MessageHandler
11 private final String id;
13 private final AdderBusinessLogic adder;
16 public void addNumber(
18 MessageAddNumber message)
20 adder.addToSum(user, message.getNext());
23 public void calculateSum(
25 MessageCalculateSum message)
27 AdderResult result = adder.calculate(user);
28 log.info("{} - New result for {}: {}", id, user, result);
31 public void handle(String user, Message message)
33 switch(message.getType())
36 addNumber(user, (MessageAddNumber) message);
40 calculateSum(user, (MessageCalculateSum) message);