X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fapi%2FMessageTo.java;h=3525d563db6e70bb86951e531d4a54b20969252c;hb=96a99d5525135668b37d88f807c8c6f0a929f94f;hp=7c72873eb97d475160b588a5d4c8b334d4f084ad;hpb=f0113ff34d7a4147ce54116680b611061244f39a;p=demos%2Fkafka%2Fchat diff --git a/src/main/java/de/juplo/kafka/chat/backend/api/MessageTo.java b/src/main/java/de/juplo/kafka/chat/backend/api/MessageTo.java index 7c72873e..3525d563 100644 --- a/src/main/java/de/juplo/kafka/chat/backend/api/MessageTo.java +++ b/src/main/java/de/juplo/kafka/chat/backend/api/MessageTo.java @@ -12,11 +12,16 @@ import java.time.LocalDateTime; public class MessageTo { private Long id; - private Long serialNumber; - private LocalDateTime timestamp; + private Long serial; + private LocalDateTime time; private String user; private String text; + public Message toMessage() + { + return new Message(Message.MessageKey.of(user, id), serial, time, text); + } + public static MessageTo from(Message message) { return @@ -24,7 +29,7 @@ public class MessageTo message.getId(), message.getSerialNumber(), message.getTimestamp(), - message.getUser(), - message.getText()); + message.getUsername(), + message.getMessageText()); } }