info.getId(),
new ChatRoomData(
clock,
- new InMemoryChatRoomService(messageFlux),
+ new InMemoryChatMessageService(messageFlux),
bufferSize));
});
this.clock = clock;
public Mono<ChatRoomInfo> createChatRoom(UUID id, String name)
{
log.info("Creating ChatRoom with buffer-size {}", bufferSize);
- ChatRoomService service = new InMemoryChatRoomService(Flux.empty());
+ ChatMessageService service = new InMemoryChatMessageService(Flux.empty());
ChatRoomInfo chatRoomInfo = new ChatRoomInfo(id, name, shard);
this.chatRoomInfo.put(id, chatRoomInfo);
ChatRoomData chatRoomData = new ChatRoomData(clock, service, bufferSize);
.switchIfEmpty(Mono.error(() -> new UnknownChatroomException(id)));
}
- public Flux<ChatRoomData> getChatRoomData()
+ @Override
+ public Mono<String[]> getShardOwners()
{
- return Flux.fromIterable(chatRoomData.values());
+ return Mono.empty();
}
}