package de.juplo.kafka.chat.backend.persistence;
import de.juplo.kafka.chat.backend.domain.*;
-import de.juplo.kafka.chat.backend.persistence.inmemory.ChatHomeService;
-import de.juplo.kafka.chat.backend.persistence.inmemory.SimpleChatHome;
import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.Test;
protected void start()
{
StorageStrategyITConfig config = getConfig();
- chathome = new SimpleChatHome(config.getChatHomeService());
+ chathome = config.getChatHome();
chatRoomFactory = config.getChatRoomFactory();
}
interface StorageStrategyITConfig
{
- ChatHomeService getChatHomeService();
+ ChatHome getChatHome();
ChatRoomFactory getChatRoomFactory();
}
}