}
- @Override
- public Mono<ChatRoom> putChatRoom(ChatRoom chatRoom)
- {
- return chatHomes[selectShard(chatRoom.getId())].putChatRoom(chatRoom);
- }
-
@Override
public Mono<ChatRoom> getChatRoom(UUID id)
{
- return chatHomes[selectShard(id)].getChatRoom(id);
+ int shard = selectShard(id);
+ if (chatHomes[shard] == null)
+ throw new ShardNotOwnedException(shard);
+ return chatHomes[shard].getChatRoom(id);
}
@Override