TEST

diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/storage/mongodb/ChatRoomTo.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/storage/mongodb/ChatRoomTo.java
index bc3863b..73b0d45 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/persistence/storage/mongodb/ChatRoomTo.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/storage/mongodb/ChatRoomTo.java
@@ -21,18 +21,11 @@ public class ChatRoomTo
   @Id
   private String id;
   private String name;
-  @DBRef
-  private List<MessageTo> messages;
 
   public static ChatRoomTo from(ChatRoom chatroom)
   {
     return new ChatRoomTo(
         chatroom.getId().toString(),
-        chatroom.getName(),
-        chatroom
-            .getMessages()
-            .map(MessageTo::from)
-            .collectList()
-            .block());
+        chatroom.getName());
   }
 }

diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/storage/mongodb/MongoDbStorageStrategy.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/storage/mongodb/MongoDbStorageStrategy.java
index 8cbbb55..3f4ba50 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/persistence/storage/mongodb/MongoDbStorageStrategy.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/storage/mongodb/MongoDbStorageStrategy.java
@@ -42,9 +42,7 @@ public class MongoDbStorageStrategy implements StorageStrategy
             chatRoomTo.getName(),
             clock,
             factory.create(
-                Flux
-                    .fromIterable(chatRoomTo.getMessages())
-                    .map(messageTo -> messageTo.toMessage())),
+                Flux.empty()),
             bufferSize));
   }
 }