1 package de.juplo.kafka.chat.backend.persistence.kafka;
3 import de.juplo.kafka.chat.backend.domain.Message;
4 import lombok.AllArgsConstructor;
6 import lombok.NoArgsConstructor;
8 import java.time.LocalDateTime;
13 @AllArgsConstructor(staticName = "of")
14 public class MessageTo
20 public Message toMessage(long offset, LocalDateTime timestamp)
22 return new Message(Message.MessageKey.of(user, id), offset, timestamp, text);
25 public static MessageTo from(Message message)
29 message.getUsername(),
31 message.getMessageText());