From: Kai Moritz Date: Sun, 3 Sep 2023 15:47:38 +0000 (+0200) Subject: WIP X-Git-Tag: rebase--2023-09-03--18-11~3 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=3860da0606090e21ab1584b8176309cdf91c8c8a;p=demos%2Fkafka%2Fchat WIP --- diff --git a/src/test/java/de/juplo/kafka/chat/backend/persistence/AbstractInMemoryStorageIT.java b/src/test/java/de/juplo/kafka/chat/backend/persistence/AbstractInMemoryStorageIT.java index bff02a36..220d26ee 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/persistence/AbstractInMemoryStorageIT.java +++ b/src/test/java/de/juplo/kafka/chat/backend/persistence/AbstractInMemoryStorageIT.java @@ -22,30 +22,18 @@ public abstract class AbstractInMemoryStorageIT extends AbstractStorageStrategyI { return new StorageStrategyITConfig() { - InMemoryChatHomeService inMemoryChatHomeService = new InMemoryChatHomeService( - 1, - new int[] { 0 }, - getStorageStrategy().read()); + int bufferSize = 8; - SimpleChatHome simpleChatHome = new SimpleChatHome(inMemoryChatHomeService); - - InMemoryChatRoomFactory chatRoomFactory = new InMemoryChatRoomFactory( - inMemoryChatHomeService, - chatRoomId -> 0, + SimpleChatHome simpleChatHome = new SimpleChatHome( + getStorageStrategy().read(), clock, - 8); + bufferSize); @Override public ChatHome getChatHome() { return simpleChatHome; } - - @Override - public ChatRoomFactory getChatRoomFactory() - { - return chatRoomFactory; - } }; } }