1 package de.juplo.kafka.chat.backend.persistence.kafka;
3 import de.juplo.kafka.chat.backend.domain.ChatRoomFactory;
4 import de.juplo.kafka.chat.backend.domain.ChatRoomInfo;
5 import lombok.RequiredArgsConstructor;
6 import lombok.extern.slf4j.Slf4j;
7 import reactor.core.publisher.Mono;
12 @RequiredArgsConstructor
14 public class KafkaChatRoomFactory implements ChatRoomFactory
16 private final ChatRoomChannel chatRoomChannel;
19 public Mono<ChatRoomInfo> createChatRoom(UUID id, String name)
21 log.info("Sending create-command for chat rooom: id={}, name={}");
22 return chatRoomChannel.sendCreateChatRoomRequest(id, name);