From d92362be8245f9a796a3e356ad90a1e2f2a1673a Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Wed, 23 Aug 2023 19:06:35 +0200 Subject: [PATCH] WIP:KafkaChatHomeTest --- .../persistence/kafka/KafkaChatHomeTest.java | 25 +++++++++++++++++++ 1 file changed, 25 insertions(+) create mode 100644 src/test/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatHomeTest.java 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; + } + + } +} -- 2.20.1