X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fpersistence%2Fkafka%2FMessageTo.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fpersistence%2Fkafka%2FMessageTo.java;h=0a867f16297502f70df5eb018df93729a07ae622;hb=0b207332e5f4a0a7a6e2f19d9c5bb3b261e8c863;hp=2de8ad58523e5107276b7ef4a72d7766766ecf8f;hpb=9c24aa2aadc3f9ae98362ccb86ab179734362800;p=demos%2Fkafka%2Fchat diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/MessageTo.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/MessageTo.java index 2de8ad58..0a867f16 100644 --- a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/MessageTo.java +++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/MessageTo.java @@ -10,11 +10,11 @@ import java.time.LocalDateTime; @Data @NoArgsConstructor -@AllArgsConstructor +@AllArgsConstructor(staticName = "of") public class MessageTo { - private Long id; private String user; + private Long id; private String text; public Message toMessage(long offset, LocalDateTime timestamp) @@ -26,8 +26,8 @@ public class MessageTo { return new MessageTo( - message.getId(), message.getUsername(), + message.getId(), message.getMessageText()); } }