package de.juplo.kafka.chat.backend.storage.mongodb;
+import de.juplo.kafka.chat.backend.ChatBackendProperties;
import de.juplo.kafka.chat.backend.implementation.ShardingStrategy;
import de.juplo.kafka.chat.backend.implementation.StorageStrategy;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
@Bean
public StorageStrategy storageStrategy(
ChatRoomRepository chatRoomRepository,
- MessageRepository messageRepository)
+ MessageRepository messageRepository,
+ ChatBackendProperties properties)
{
- return new MongoDbStorageStrategy(chatRoomRepository, messageRepository);
+ return new MongoDbStorageStrategy(
+ chatRoomRepository,
+ messageRepository,
+ properties.getProjectreactor().getLoggingLevel(),
+ properties.getProjectreactor().isShowOperatorLine());
}
}