package de.juplo.kafka.chat.backend.persistence.kafka;
import de.juplo.kafka.chat.backend.ChatBackendProperties;
-import de.juplo.kafka.chat.backend.domain.ChatHome;
+import de.juplo.kafka.chat.backend.domain.ChatHomeService;
import de.juplo.kafka.chat.backend.persistence.kafka.messages.AbstractMessageTo;
import de.juplo.kafka.chat.backend.persistence.kafka.messages.CommandCreateChatRoomTo;
import de.juplo.kafka.chat.backend.persistence.kafka.messages.EventChatMessageReceivedTo;
public class KafkaServicesConfiguration
{
@Bean
- ChatHome kafkaChatHome(
+ ChatHomeService kafkaChatHome(
ChatBackendProperties properties,
ChatRoomChannel chatRoomChannel)
{
- return new KafkaChatHome(
+ return new KafkaChatHomeService(
properties.getKafka().getNumPartitions(),
chatRoomChannel);
}