X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fdomain%2FChatHomeWithShardsTestBase.java;h=587c754ebe8601f26098bffdcbac8e4749db6e0c;hb=3cb0ac8b376573c1229ee525d83611b8af7a7a2b;hp=a417e6f95067a107d1a6b3d097fe10b6ad683553;hpb=bb1f9a4b980e35790cef4892063ab6186f2b7084;p=demos%2Fkafka%2Fchat

diff --git a/src/test/java/de/juplo/kafka/chat/backend/domain/ChatHomeWithShardsTestBase.java b/src/test/java/de/juplo/kafka/chat/backend/domain/ChatHomeWithShardsTestBase.java
index a417e6f9..587c754e 100644
--- a/src/test/java/de/juplo/kafka/chat/backend/domain/ChatHomeWithShardsTestBase.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/domain/ChatHomeWithShardsTestBase.java
@@ -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);
     });
   }
 }