X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fpersistence%2Fkafka%2FKafkaChatRoomFactory.java;h=23bd921d5493ddd1eb57c3dadc128a4e36b6b9ee;hb=13c51b4630177e7f6649500a3d4b876a12509af6;hp=f81d21f118b855c434f5f824bc99b61421c9e142;hpb=915ed8f85459da3c95f86b6351a3d7129668bc8e;p=demos%2Fkafka%2Fchat diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatRoomFactory.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatRoomFactory.java index f81d21f1..23bd921d 100644 --- a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatRoomFactory.java +++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatRoomFactory.java @@ -2,7 +2,7 @@ package de.juplo.kafka.chat.backend.persistence.kafka; import de.juplo.kafka.chat.backend.domain.ChatRoom; import de.juplo.kafka.chat.backend.domain.ChatRoomFactory; -import de.juplo.kafka.chat.backend.domain.ChatRoomService; +import de.juplo.kafka.chat.backend.domain.ChatRoomInfo; import de.juplo.kafka.chat.backend.domain.ShardingStrategy; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; @@ -16,18 +16,15 @@ import java.util.UUID; @Slf4j public class KafkaChatRoomFactory implements ChatRoomFactory { - private final KafkaChatHomeService kafkaChatHomeService; - private final ShardingStrategy shardingStrategy; - private final Clock clock; - private final int bufferSize; + private final ChatRoomChannel chatRoomChannel; @Override - public Mono createChatRoom(UUID id, String name) + public Mono createChatRoom(UUID id, String name) { log.info("Creating ChatRoom with buffer-size {}", bufferSize); - int shard = shardingStrategy.selectShard(id); - KafkaChatRoomService service = new KafkaChatRoomService(kafkaChatHomeService, id); + KafkaChatRoomService service = new KafkaChatRoomService(chatRoomChannel, id); ChatRoom chatRoom = new ChatRoom(id, name, shard, clock, service, bufferSize); - kafkaChatHomeService.putChatRoom(chatRoom); + chatRoomChannel.putChatRoom(chatRoom); + return Mono.just(chatRoom); } }