WIP:test: Simp...
[demos/kafka/chat] / src / test / java / de / juplo / kafka / chat / backend / domain / ChatHomeWithShardsTestBase.java
index a417e6f..587c754 100644 (file)
@@ -24,9 +24,9 @@ public class ChatHomeWithShardsTestBase extends ChatHomeTestBase
     // Then
     assertThat(mono).sendsError(e ->
     {
-      assertThat(e).isInstanceOf(UnknownChatroomException.class);
-      UnknownChatroomException unknownChatroomException = (UnknownChatroomException) e;
-      assertThat(unknownChatroomException.getChatroomId()).isEqualTo(chatRoomId);
+      assertThat(e).isInstanceOf(ShardNotOwnedException.class);
+      ShardNotOwnedException shardNotOwnedException = (ShardNotOwnedException) e;
+      assertThat(shardNotOwnedException.getShard()).isEqualTo(0);
     });
   }
 }