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 c024b65da7d2e2d57edcc215c745473a6dc40e2c..940aed334d915640f404046953f685373666e38a 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 afc5a393758853ff343f77879414895b6454e1d2..07f0dc829a0311294af67655bc7a0c3985428324 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 e4999b77da74873b72d584b8b81dbc13b4a3b2b8..a20076f47f6e6823d9fdb8da38ce031ab9c7d1ed 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 82116f43205dc3fbfd1e364365acd94c5a9d884a..6092706f55500aca22f8866fe7e56547e2024ef4 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));
   }
 }