WIP - Ein Versuch (vielleicht Unsinn)

[demos/kafka/chat] / src / main / java / de / juplo / kafka / chat / backend / domain / Message.java

diff --git a/src/main/java/de/juplo/kafka/chat/backend/domain/Message.java b/src/main/java/de/juplo/kafka/chat/backend/domain/Message.java
index c5b738f..c0dd861 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/domain/Message.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/domain/Message.java
@@ -1,9 +1,6 @@
 package de.juplo.kafka.chat.backend.domain;
 
-import lombok.EqualsAndHashCode;
-import lombok.Getter;
-import lombok.RequiredArgsConstructor;
-import lombok.ToString;
+import lombok.*;
 
 import java.time.LocalDateTime;
 
@@ -14,9 +11,26 @@ import java.time.LocalDateTime;
 @ToString
 public class Message
 {
-  private final Long id;
+  private final MessageKey key;
   private final Long serialNumber;
   private final LocalDateTime timestamp;
-  private final String username;
   private final String messageText;
+
+  public Long getId()
+  {
+    return key.messageId;
+  }
+
+  public String getUsername()
+  {
+    return key.username;
+  }
+
+
+  @Value(staticConstructor = "of")
+  public static class MessageKey
+  {
+    String username;
+    Long messageId;
+  }
 }