1 package de.juplo.kafka.chat.backend.persistence.kafka;
3 import de.juplo.kafka.chat.backend.domain.Message;
6 import java.time.LocalDateTime;
10 public class ChatMessageTo extends AbstractTo
17 public ChatMessageTo()
19 super(ToType.MESSAGE_SENT);
23 public Message toMessage(long offset, LocalDateTime timestamp)
25 return new Message(Message.MessageKey.of(user, id), offset, timestamp, text);
28 public static ChatMessageTo from(Message message)
30 return ChatMessageTo.of(
31 message.getUsername(),
33 message.getMessageText());
37 public static ChatMessageTo of(String user, Long id, String text)
39 ChatMessageTo to = new ChatMessageTo();