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
   9
  10 public class MessageTest
  11 {
  12   ObjectMapper mapper = new ObjectMapper();
  13
  14   @Test
  15   @DisplayName("Deserialize a MessageAddNumber message")
  16   public void testDeserializeMessageAddNumber()
  17   {
  18     Assertions.assertDoesNotThrow(() -> mapper.readValue("{\"next\":42}", MessageAddNumber.class));
  19     Assertions.assertDoesNotThrow(() -> mapper.readValue("{\"number\":666,\"next\":42}", MessageAddNumber.class));
  20   }
  21
  22   @Test
  23   @DisplayName("Deserialize a MessageCalculateSum message")
  24   public void testDeserializeMessageCalculateSum() throws JsonProcessingException
  25   {
  26     Assertions.assertDoesNotThrow(() -> mapper.readValue("{}", MessageCalculateSum.class));
  27     Assertions.assertDoesNotThrow(() -> mapper.readValue("{\"number\":666}", MessageCalculateSum.class));
  28   }
  29 }