X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fdomain%2FChatHomeServiceWithShardsTest.java;h=5eeac471037d3f3041b86ffe02c52e6ee46cffde;hb=776611f342394a04011e1c5a6093ef18003d3d05;hp=65a67b9956fb62600c1901282aa891aafac1e247;hpb=dea105295915406736750ce91ee893a7893cdd23;p=demos%2Fkafka%2Fchat diff --git a/src/test/java/de/juplo/kafka/chat/backend/domain/ChatHomeServiceWithShardsTest.java b/src/test/java/de/juplo/kafka/chat/backend/domain/ChatHomeServiceWithShardsTest.java index 65a67b99..5eeac471 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/domain/ChatHomeServiceWithShardsTest.java +++ b/src/test/java/de/juplo/kafka/chat/backend/domain/ChatHomeServiceWithShardsTest.java @@ -13,7 +13,7 @@ import java.util.UUID; import static pl.rzrz.assertj.reactor.Assertions.assertThat; -public abstract class ChatHomeWithShardsTest extends ChatHomeTest +public abstract class ChatHomeServiceWithShardsTest extends ChatHomeServiceTest { public static final int NUM_SHARDS = 10; public static final int OWNED_SHARD = 2; @@ -29,7 +29,7 @@ public abstract class ChatHomeWithShardsTest extends ChatHomeTest // When Mono mono = Mono - .defer(() -> chatHome.getChatRoomData(chatRoomId)) + .defer(() -> chatHomeService.getChatRoomData(chatRoomId)) .log("testGetChatroomForNotOwnedShard") .retryWhen(Retry .backoff(5, Duration.ofSeconds(1))