X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fdomain%2FChatHomeWithShardsTestBase.java;h=c7f8c119ba8219121e89c4c52aa3d21e57006402;hb=586d8662e763c75eb689735bd6d99e240fee8e4b;hp=587c754ebe8601f26098bffdcbac8e4749db6e0c;hpb=4052e4fd9b020c340b6d5e7465085da96c3dfff5;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 587c754e..c7f8c119 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 @@ -11,6 +11,11 @@ import static pl.rzrz.assertj.reactor.Assertions.assertThat; public class ChatHomeWithShardsTestBase extends ChatHomeTestBase { + public static final int NUM_SHARDS = 10; + public static final int OWNED_SHARD = 2; + public static final int NOT_OWNED_SHARD = 0; + + @Test @DisplayName("Assert ShardNotOwnedException is thrown, if the shard for the chatroom is not owned") void testGetChatroomForNotOwnedShard() @@ -26,7 +31,7 @@ public class ChatHomeWithShardsTestBase extends ChatHomeTestBase { assertThat(e).isInstanceOf(ShardNotOwnedException.class); ShardNotOwnedException shardNotOwnedException = (ShardNotOwnedException) e; - assertThat(shardNotOwnedException.getShard()).isEqualTo(0); + assertThat(shardNotOwnedException.getShard()).isEqualTo(NOT_OWNED_SHARD); }); } }