import de.juplo.kafka.chat.backend.domain.ChatHome;
import de.juplo.kafka.chat.backend.domain.ChatRoom;
-import de.juplo.kafka.chat.backend.domain.ShardNotOwnedException;
import de.juplo.kafka.chat.backend.domain.ShardingStrategy;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
public class KafkaChatHome implements ChatHome
{
private final ShardingStrategy shardingStrategy;
+ private final ChatRoomChannel chatRoomChannel;
private final ChatMessageChannel chatMessageChanel;
}
@Override
- public Flux<ChatRoom> getChatRooms()
+ public Flux<ChatRoomInfo> getChatRooms()
{
- if (chatMessageChanel.isLoadInProgress())
- {
- throw new LoadInProgressException();
- }
- else
- {
- return chatMessageChanel.getChatRooms();
- }
+ return chatRoomChannel.getChatRooms();
}
}