From 167b1951b859125994427df7672b4416646fe70f Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Fri, 15 Sep 2023 11:45:40 +0200 Subject: [PATCH] WIP:ALIGN --- .../implementation/kafka/KafkaChatHomeServiceTest.java | 6 +++--- .../chat/backend/implementation/kafka/KafkaTestUtils.java | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaChatHomeServiceTest.java b/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaChatHomeServiceTest.java index b5bc301b..f12775ab 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaChatHomeServiceTest.java +++ b/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaChatHomeServiceTest.java @@ -27,7 +27,7 @@ import static de.juplo.kafka.chat.backend.implementation.kafka.KafkaChatHomeServ "chat.backend.kafka.data-channel-topic=" + DATA_TOPIC, "chat.backend.kafka.num-partitions=" + NUM_SHARDS, }) -@Import(KafkaTestConfiguration.class) +@Import(KafkaTestUtils.class) @EmbeddedKafka( topics = { INFO_TOPIC, DATA_TOPIC }, partitions = 10) @@ -42,7 +42,7 @@ public class KafkaChatHomeServiceTest extends ChatHomeServiceWithShardsTest @Autowired ConsumerTaskRunner consumerTaskRunner, @Autowired KafkaTemplate messageTemplate) { - KafkaTestConfiguration.sendAndLoadStoredData( + KafkaTestUtils.sendAndLoadStoredData( consumerTaskRunner, messageTemplate); } @@ -50,6 +50,6 @@ public class KafkaChatHomeServiceTest extends ChatHomeServiceWithShardsTest @AfterAll static void joinConsumerTasks(@Autowired ConsumerTaskRunner consumerTaskRunner) { - KafkaTestConfiguration.joinConsumerTasks(consumerTaskRunner); + KafkaTestUtils.joinConsumerTasks(consumerTaskRunner); } } diff --git a/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaTestUtils.java b/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaTestUtils.java index 4b19897a..52727290 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaTestUtils.java +++ b/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaTestUtils.java @@ -30,7 +30,7 @@ import static de.juplo.kafka.chat.backend.implementation.kafka.KafkaChatHomeServ "spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}", }) @Slf4j -public abstract class KafkaTestConfiguration +public abstract class KafkaTestUtils { @Bean WorkAssignor dataChannelWorkAssignor(DataChannel dataChannel) -- 2.20.1