From 13e3e7edbd728fb3398174662a09af69533a911e Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 2 Feb 2025 17:26:45 +0100 Subject: [PATCH] Nachrichten verschoben und umbenannt -- ALIGN --- src/main/java/de/juplo/messages/Add.java | 4 ++-- src/main/java/de/juplo/messages/Calculate.java | 4 ++-- src/main/java/de/juplo/messages/Message.java | 2 +- src/test/java/de/juplo/messages/MessageTest.java | 10 +++++----- 4 files changed, 10 insertions(+), 10 deletions(-) diff --git a/src/main/java/de/juplo/messages/Add.java b/src/main/java/de/juplo/messages/Add.java index c024b65d..940aed33 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 afc5a393..07f0dc82 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 e4999b77..a20076f4 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 82116f43..6092706f 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)); } } -- 2.20.1