1 package de.juplo.kafka.chat.backend.domain;
3 import org.junit.jupiter.api.DisplayName;
4 import org.junit.jupiter.api.Test;
5 import reactor.core.publisher.Mono;
9 import static pl.rzrz.assertj.reactor.Assertions.assertThat;
12 public class ChatHomeWithShardsTestBase extends ChatHomeTestBase
15 @DisplayName("Assert ShardNotOwnedException is thrown, if the shard for the chatroom is not owned")
16 void testGetChatroomForNotOwnedShard()
19 UUID chatRoomId = UUID.fromString("4e7246a6-29ae-43ea-b56f-669c3481ac19");
22 Mono<ChatRoom> mono = chatHome.getChatRoom(chatRoomId);
25 assertThat(mono).sendsError(e ->
27 assertThat(e).isInstanceOf(ShardNotOwnedException.class);
28 ShardNotOwnedException shardNotOwnedException = (ShardNotOwnedException) e;
29 assertThat(shardNotOwnedException.getShard()).isEqualTo(0);