juplo.de Git - demos/kafka/training/blob - src/test/java/de/juplo/kafka/MessageTest.java

   1 package de.juplo.kafka;
   2
   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;
  12
  13 import java.util.Arrays;
  14 import java.util.stream.IntStream;
  15 import java.util.stream.Stream;
  16
  17 import static org.assertj.core.api.Assertions.*;
  18
  19
  20 public class MessageTest
  21 {
  22   ObjectMapper mapper = new ObjectMapper();
  23
  24   @Test
  25   @DisplayName("Deserialize a MessageAddNumber message")
  26   public void testDeserializeMessageAddNumber()
  27   {
  28     Assertions.assertDoesNotThrow(() -> mapper.readValue("{\"next\":42}", MessageAddNumber.class));
  29     Assertions.assertDoesNotThrow(() -> mapper.readValue("{\"number\":666,\"next\":42}", MessageAddNumber.class));
  30   }
  31
  32   @Test
  33   @DisplayName("Deserialize a MessageCalculateSum message")
  34   public void testDeserializeMessageCalculateSum() throws JsonProcessingException
  35   {
  36     Assertions.assertDoesNotThrow(() -> mapper.readValue("{}", MessageCalculateSum.class));
  37     Assertions.assertDoesNotThrow(() -> mapper.readValue("{\"number\":666}", MessageCalculateSum.class));
  38   }
  39 }