From: Kai Moritz <kai@juplo.de>
Date: Sun, 2 Feb 2025 16:26:45 +0000 (+0100)
Subject: Nachrichten verschoben und umbenannt -- ALIGN
X-Git-Tag: spring/sumup-messages--vorlage--2025-04-signal-spickzettel~1
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=00c729d3f7208df852c1ea5d2d79ac06cb7e44c6;p=demos%2Fkafka%2Ftraining

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
--- 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
--- 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
--- 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
--- 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));
   }
 }