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 (file)
index 0000000..ee5fe0f
--- /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 (file)
index ee5fe0f..0000000
--- 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 (file)
index 20a0f5c..0000000
--- 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 (file)
index 0000000..20a0f5c
--- /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;
+  }
+}