Nachrichten verschoben und umbenannt -- ALIGN

diff --git a/src/main/java/de/juplo/messages/Add.java b/src/main/java/de/juplo/messages/Add.java
index c024b65..940aed3 100644 (file)
--- a/src/main/java/de/juplo/messages/Add.java
+++ b/src/main/java/de/juplo/messages/Add.java
@@ -1,4 +1,4 @@
-package de.juplo.kafka;
+package de.juplo.messages;
 
 import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
 import lombok.Data;
@@ -6,7 +6,7 @@ import lombok.Data;
 
 @Data
 @JsonIgnoreProperties(ignoreUnknown = true)
-public class MessageAddNumber extends Message
+public class Add extends Message
 {
   private Integer next;
 

diff --git a/src/main/java/de/juplo/messages/Calculate.java b/src/main/java/de/juplo/messages/Calculate.java
index afc5a39..07f0dc8 100644 (file)
--- a/src/main/java/de/juplo/messages/Calculate.java
+++ b/src/main/java/de/juplo/messages/Calculate.java
@@ -1,4 +1,4 @@
-package de.juplo.kafka;
+package de.juplo.messages;
 
 import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
 import lombok.Data;
@@ -6,7 +6,7 @@ import lombok.Data;
 
 @Data
 @JsonIgnoreProperties(ignoreUnknown = true)
-public class MessageCalculateSum extends Message
+public class Calculate extends Message
 {
   @Override
   public Type getType()

diff --git a/src/main/java/de/juplo/messages/Message.java b/src/main/java/de/juplo/messages/Message.java
index e4999b7..a20076f 100644 (file)
--- a/src/main/java/de/juplo/messages/Message.java
+++ b/src/main/java/de/juplo/messages/Message.java
@@ -1,4 +1,4 @@
-package de.juplo.kafka;
+package de.juplo.messages;
 
 
 public abstract class Message

diff --git a/src/test/java/de/juplo/messages/MessageTest.java b/src/test/java/de/juplo/messages/MessageTest.java
index 82116f4..6092706 100644 (file)
--- a/src/test/java/de/juplo/messages/MessageTest.java
+++ b/src/test/java/de/juplo/messages/MessageTest.java
@@ -1,4 +1,4 @@
-package de.juplo.kafka;
+package de.juplo.messages;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
@@ -15,15 +15,15 @@ public class MessageTest
   @DisplayName("Deserialize a MessageAddNumber message")
   public void testDeserializeMessageAddNumber()
   {
-    Assertions.assertDoesNotThrow(() -> mapper.readValue("{\"next\":42}", MessageAddNumber.class));
-    Assertions.assertDoesNotThrow(() -> mapper.readValue("{\"number\":666,\"next\":42}", MessageAddNumber.class));
+    Assertions.assertDoesNotThrow(() -> mapper.readValue("{\"next\":42}", Add.class));
+    Assertions.assertDoesNotThrow(() -> mapper.readValue("{\"number\":666,\"next\":42}", Add.class));
   }
 
   @Test
   @DisplayName("Deserialize a MessageCalculateSum message")
   public void testDeserializeMessageCalculateSum() throws JsonProcessingException
   {
-    Assertions.assertDoesNotThrow(() -> mapper.readValue("{}", MessageCalculateSum.class));
-    Assertions.assertDoesNotThrow(() -> mapper.readValue("{\"number\":666}", MessageCalculateSum.class));
+    Assertions.assertDoesNotThrow(() -> mapper.readValue("{}", Calculate.class));
+    Assertions.assertDoesNotThrow(() -> mapper.readValue("{\"number\":666}", Calculate.class));
   }
 }