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

   1 package de.juplo.kafka.chat.backend;
   2
   3 import de.juplo.kafka.chat.backend.domain.ChatHomeService;
   4 import de.juplo.kafka.chat.backend.implementation.inmemory.SimpleChatHomeService;
   5 import lombok.RequiredArgsConstructor;
   6 import lombok.extern.slf4j.Slf4j;
   7
   8 import java.time.Clock;
   9
  10
  11 @RequiredArgsConstructor
  12 @Slf4j
  13 public abstract class AbstractInMemoryStorageIT extends AbstractStorageStrategyIT
  14 {
  15   final Clock clock;
  16
  17   @Override
  18   protected StorageStrategyITConfig getConfig()
  19   {
  20     return new StorageStrategyITConfig()
  21     {
  22       int bufferSize = 8;
  23
  24       SimpleChatHomeService simpleChatHome = new SimpleChatHomeService(
  25           getStorageStrategy(),
  26           clock,
  27           bufferSize);
  28
  29       @Override
  30       public ChatHomeService getChatHome()
  31       {
  32         return simpleChatHome;
  33       }
  34     };
  35   }
  36 }