juplo.de Git - demos/kafka/chat/blob - src/main/java/de/juplo/kafka/chat/backend/domain/Message.java

   1 package de.juplo.kafka.chat.backend.domain;
   2
   3 import lombok.*;
   4
   5 import java.time.LocalDateTime;
   6
   7
   8 @RequiredArgsConstructor
   9 @Getter
  10 @EqualsAndHashCode
  11 @ToString
  12 public class Message
  13 {
  14   private final MessageKey key;
  15   private final Long serialNumber;
  16   private final LocalDateTime timestamp;
  17   private final String messageText;
  18
  19   public Long getId()
  20   {
  21     return key.messageId;
  22   }
  23
  24   public String getUsername()
  25   {
  26     return key.username;
  27   }
  28
  29
  30   @Value(staticConstructor = "of")
  31   public static class MessageKey
  32   {
  33     String username;
  34     Long messageId;
  35   }
  36 }