From: Kai Moritz <kai@juplo.de>
Date: Wed, 23 Aug 2023 17:06:35 +0000 (+0200)
Subject: WIP:KafkaChatHomeTest
X-Git-Tag: wip-kafka-chat-home-test--springboot~6
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=d92362be8245f9a796a3e356ad90a1e2f2a1673a;p=demos%2Fkafka%2Fchat

WIP:KafkaChatHomeTest
---

diff --git a/src/test/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatHomeTest.java b/src/test/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatHomeTest.java
new file mode 100644
index 00000000..ab24082a
--- /dev/null
+++ b/src/test/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatHomeTest.java
@@ -0,0 +1,25 @@
+package de.juplo.kafka.chat.backend.persistence.kafka;
+
+import de.juplo.kafka.chat.backend.domain.ChatHomeWithShardsTestBase;
+import org.springframework.boot.test.context.TestConfiguration;
+import org.springframework.context.annotation.Bean;
+
+
+public class KafkaChatHomeTest extends ChatHomeWithShardsTestBase
+{
+  @TestConfiguration
+  static class Configuration
+  {
+    @Bean
+    KafkaChatHome chatHome(ChatRoomChannel chatRoomChannel)
+    {
+      return new KafkaChatHome(numShards(), chatRoomChannel);
+    }
+
+    Integer numShards()
+    {
+      return 10;
+    }
+
+  }
+}