@Slf4j
public class SimpleChatHome implements ChatHome
{
- private final ChatHomeService service;
+ private final InMemoryChatHomeService service;
private final int shard;
- public SimpleChatHome(ChatHomeService service, int shard)
+ public SimpleChatHome(InMemoryChatHomeService service, int shard)
{
log.info("Created SimpleChatHome for shard {}", shard);
this.service = service;
this.shard = shard;
}
- public SimpleChatHome(ChatHomeService service)
+ public SimpleChatHome(InMemoryChatHomeService service)
{
this(service, 0);
}
{
return service
.getChatRoom(shard, id)
- .switchIfEmpty(Mono.error(() -> new UnknownChatroomException(id)));
+ .switchIfEmpty(Mono.error(() -> new UnknownChatroomException(
+ id,
+ shard,
+ service.getOwnedShards())));
}
@Override