1 package de.juplo.kafka;
3 import com.fasterxml.jackson.core.JsonProcessingException;
4 import com.fasterxml.jackson.databind.ObjectMapper;
5 import org.junit.jupiter.api.Assertions;
6 import org.junit.jupiter.api.DisplayName;
7 import org.junit.jupiter.api.Test;
10 public class MessageTest
12 ObjectMapper mapper = new ObjectMapper();
15 @DisplayName("Deserialize a MessageAddNumber message")
16 public void testDeserializeMessageAddNumber()
18 Assertions.assertDoesNotThrow(() -> mapper.readValue("{\"next\":42}", MessageAddNumber.class));
19 Assertions.assertDoesNotThrow(() -> mapper.readValue("{\"number\":666,\"next\":42}", MessageAddNumber.class));
23 @DisplayName("Deserialize a MessageCalculateSum message")
24 public void testDeserializeMessageCalculateSum() throws JsonProcessingException
26 Assertions.assertDoesNotThrow(() -> mapper.readValue("{}", MessageCalculateSum.class));
27 Assertions.assertDoesNotThrow(() -> mapper.readValue("{\"number\":666}", MessageCalculateSum.class));