1 package de.juplo.kafka.chat.backend.storage.mongodb;
3 import de.juplo.kafka.chat.backend.ChatBackendProperties;
4 import de.juplo.kafka.chat.backend.implementation.ShardingStrategy;
5 import de.juplo.kafka.chat.backend.implementation.StorageStrategy;
6 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
7 import org.springframework.context.annotation.Bean;
8 import org.springframework.context.annotation.Configuration;
11 @ConditionalOnProperty(
12 prefix = "chat.backend.inmemory",
13 name = "storage-strategy",
14 havingValue = "mongodb")
16 public class MongoDbStorageConfiguration
19 public StorageStrategy storageStrategy(
20 ChatRoomRepository chatRoomRepository,
21 MessageRepository messageRepository,
22 ChatBackendProperties properties)
24 return new MongoDbStorageStrategy(
27 properties.getProjectreactor().getLoggingLevel(),
28 properties.getProjectreactor().isShowOperatorLine());