From 4d5794b2623278e68db9bdb06c6fff87ccf2f42c Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Mon, 9 Jan 2023 22:49:44 +0100 Subject: [PATCH] WIP --- .../mongodb/MongoDbStorageStrategy.java | 21 +++++++++++++++++++ 1 file changed, 21 insertions(+) create mode 100644 src/main/java/de/juplo/kafka/chat/backend/persistence/storage/mongodb/MongoDbStorageStrategy.java 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 new file mode 100644 index 00000000..ccf3d696 --- /dev/null +++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/storage/mongodb/MongoDbStorageStrategy.java @@ -0,0 +1,21 @@ +package de.juplo.kafka.chat.backend.persistence.storage.mongodb; + +import de.juplo.kafka.chat.backend.domain.ChatRoom; +import de.juplo.kafka.chat.backend.persistence.StorageStrategy; +import reactor.core.publisher.Flux; + + +public class MongoDbStorageStrategy implements StorageStrategy +{ + @Override + public void write(Flux chatroomFlux) + { + + } + + @Override + public Flux read() + { + return null; + } +} -- 2.20.1