X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fapi%2FChatBackendControllerTest.java;fp=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fapi%2FChatBackendControllerTest.java;h=5ebd08d1e9209a28d2d25485e271d4781aa42e7a;hb=3526be7c01fa286f4253c96fd7f6c35abf3694ef;hp=12d34be1774642152bfd700bdd56954fecfb6f08;hpb=ff98b068a91fc9e60e51bd4a95065633bb8ed2db;p=demos%2Fkafka%2Fchat diff --git a/src/test/java/de/juplo/kafka/chat/backend/api/ChatBackendControllerTest.java b/src/test/java/de/juplo/kafka/chat/backend/api/ChatBackendControllerTest.java index 12d34be1..5ebd08d1 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/api/ChatBackendControllerTest.java +++ b/src/test/java/de/juplo/kafka/chat/backend/api/ChatBackendControllerTest.java @@ -262,12 +262,12 @@ public class ChatBackendControllerTest @Bean ChatHome[] chatHomes( ChatBackendProperties properties, - ChatHomeFactory factory) + InMemoryChatHomeService service) { ChatHome[] chatHomes = new ChatHome[properties.getInmemory().getNumShards()]; Arrays .stream(properties.getInmemory().getOwnedShards()) - .forEach(i -> chatHomes[i] = factory.createChatHome(i)); + .forEach(i -> chatHomes[i] = new ChatHome(service, i)); return chatHomes; } }