From: Kai Moritz Date: Mon, 11 Sep 2023 17:00:31 +0000 (+0200) Subject: WIP:MOVE X-Git-Tag: rebase--2023-09-13--21-01~13 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=b679663b4109eb753bf2522f029e72bfb2becd0a;p=demos%2Fkafka%2Fchat WIP:MOVE --- diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/messages/data/CommandCreateChatRoomTo.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/messages/data/CommandCreateChatRoomTo.java new file mode 100644 index 00000000..ee5fe0f8 --- /dev/null +++ b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/messages/data/CommandCreateChatRoomTo.java @@ -0,0 +1,27 @@ +package de.juplo.kafka.chat.backend.implementation.kafka.messages.data; + +import lombok.*; + + +@Getter +@Setter +@EqualsAndHashCode +@ToString +public class CommandCreateChatRoomToData extends AbstractDataMessageTo +{ + private String name; + + + public CommandCreateChatRoomToData() + { + super(ToType.COMMAND_CREATE_CHATROOM); + } + + + public static CommandCreateChatRoomToData of(String name) + { + CommandCreateChatRoomToData to = new CommandCreateChatRoomToData(); + to.name = name; + return to; + } +} diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/messages/data/CommandCreateChatRoomToData.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/messages/data/CommandCreateChatRoomToData.java deleted file mode 100644 index ee5fe0f8..00000000 --- a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/messages/data/CommandCreateChatRoomToData.java +++ /dev/null @@ -1,27 +0,0 @@ -package de.juplo.kafka.chat.backend.implementation.kafka.messages.data; - -import lombok.*; - - -@Getter -@Setter -@EqualsAndHashCode -@ToString -public class CommandCreateChatRoomToData extends AbstractDataMessageTo -{ - private String name; - - - public CommandCreateChatRoomToData() - { - super(ToType.COMMAND_CREATE_CHATROOM); - } - - - public static CommandCreateChatRoomToData of(String name) - { - CommandCreateChatRoomToData to = new CommandCreateChatRoomToData(); - to.name = name; - return to; - } -} diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/messages/data/EventChatDataMessageReceivedTo.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/messages/data/EventChatDataMessageReceivedTo.java deleted file mode 100644 index 20a0f5ca..00000000 --- a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/messages/data/EventChatDataMessageReceivedTo.java +++ /dev/null @@ -1,31 +0,0 @@ -package de.juplo.kafka.chat.backend.implementation.kafka.messages.data; - -import lombok.*; - - -@Getter -@Setter -@EqualsAndHashCode -@ToString -public class EventChatDataMessageReceivedTo extends AbstractDataMessageTo -{ - private String user; - private Long id; - private String text; - - - public EventChatDataMessageReceivedTo() - { - super(ToType.EVENT_CHATMESSAGE_RECEIVED); - } - - - public static EventChatDataMessageReceivedTo of(String user, Long id, String text) - { - EventChatDataMessageReceivedTo to = new EventChatDataMessageReceivedTo(); - to.user = user; - to.id = id; - to.text = text; - return to; - } -} diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/messages/data/EventChatMessageReceivedTo.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/messages/data/EventChatMessageReceivedTo.java new file mode 100644 index 00000000..20a0f5ca --- /dev/null +++ b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/messages/data/EventChatMessageReceivedTo.java @@ -0,0 +1,31 @@ +package de.juplo.kafka.chat.backend.implementation.kafka.messages.data; + +import lombok.*; + + +@Getter +@Setter +@EqualsAndHashCode +@ToString +public class EventChatDataMessageReceivedTo extends AbstractDataMessageTo +{ + private String user; + private Long id; + private String text; + + + public EventChatDataMessageReceivedTo() + { + super(ToType.EVENT_CHATMESSAGE_RECEIVED); + } + + + public static EventChatDataMessageReceivedTo of(String user, Long id, String text) + { + EventChatDataMessageReceivedTo to = new EventChatDataMessageReceivedTo(); + to.user = user; + to.id = id; + to.text = text; + return to; + } +}