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;
8 import org.junit.jupiter.params.ParameterizedTest;
9 import org.junit.jupiter.params.provider.Arguments;
10 import org.junit.jupiter.params.provider.MethodSource;
11 import org.junit.jupiter.params.provider.ValueSource;
13 import java.util.Arrays;
14 import java.util.stream.IntStream;
15 import java.util.stream.Stream;
17 import static org.assertj.core.api.Assertions.*;
20 public class MessageTest
22 ObjectMapper mapper = new ObjectMapper();
25 @DisplayName("Deserialize a MessageAddNumber message")
26 public void testDeserializeMessageAddNumber()
28 Assertions.assertDoesNotThrow(() -> mapper.readValue("{\"next\":42}", MessageAddNumber.class));
29 Assertions.assertDoesNotThrow(() -> mapper.readValue("{\"number\":666,\"next\":42}", MessageAddNumber.class));
33 @DisplayName("Deserialize a MessageCalculateSum message")
34 public void testDeserializeMessageCalculateSum() throws JsonProcessingException
36 Assertions.assertDoesNotThrow(() -> mapper.readValue("{}", MessageCalculateSum.class));
37 Assertions.assertDoesNotThrow(() -> mapper.readValue("{\"number\":666}", MessageCalculateSum.class));