juplo.de Git - demos/kafka/chat/blob - src/test/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatHomeTest.java

   1 package de.juplo.kafka.chat.backend.persistence.kafka;
   2
   3 import de.juplo.kafka.chat.backend.domain.ChatHomeWithShardsTestBase;
   4 import org.springframework.boot.test.context.TestConfiguration;
   5 import org.springframework.context.annotation.Bean;
   6
   7
   8 public class KafkaChatHomeTest extends ChatHomeWithShardsTestBase
   9 {
  10   @TestConfiguration
  11   static class Configuration
  12   {
  13     @Bean
  14     KafkaChatHome chatHome(ChatRoomChannel chatRoomChannel)
  15     {
  16       return new KafkaChatHome(numShards(), chatRoomChannel);
  17     }
  18
  19     Integer numShards()
  20     {
  21       return 10;
  22     }
  23
  24   }
  25 }