1 package de.juplo.kafka;
3 import lombok.extern.slf4j.Slf4j;
4 import org.springframework.beans.factory.annotation.Autowired;
5 import org.springframework.beans.factory.annotation.Value;
6 import org.springframework.stereotype.Component;
11 public class MessageHandler
13 @Value("${spring.kafka.client-id}")
16 private AdderBusinessLogic adder;
19 public void addNumber(
21 MessageAddNumber message)
23 adder.addToSum(user, message.getNext());
26 public void calculateSum(
28 MessageCalculateSum message)
30 AdderResult result = adder.calculate(user);
31 log.info("{} - New result for {}: {}", id, user, result);
34 public void handle(String user, Message message)
36 switch(message.getType())
39 addNumber(user, (MessageAddNumber) message);
43 calculateSum(user, (MessageCalculateSum) message);