import de.juplo.kafka.chat.backend.ChatBackendProperties;
import de.juplo.kafka.chat.backend.domain.*;
import de.juplo.kafka.chat.backend.persistence.inmemory.InMemoryChatHomeService;
+import de.juplo.kafka.chat.backend.persistence.inmemory.ShardingStrategy;
import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Test;
// Given
UUID chatroomId = getRandomIdForOwnedShard();
when(chatHomeService.getChatRoom(anyInt(), any(UUID.class))).thenReturn(Mono.empty());
+ when(chatHomeService.getOwnedShards()).thenReturn(new int[] { 6 });
// When
WebTestClient.ResponseSpec responseSpec = client
// Given
UUID chatroomId = getRandomIdForOwnedShard();
when(chatHomeService.getChatRoom(anyInt(), any(UUID.class))).thenReturn(Mono.empty());
+ when(chatHomeService.getOwnedShards()).thenReturn(new int[] { 6 });
// When
WebTestClient.ResponseSpec responseSpec = client
String username = "foo";
Long messageId = 66l;
when(chatHomeService.getChatRoom(anyInt(), any(UUID.class))).thenReturn(Mono.empty());
+ when(chatHomeService.getOwnedShards()).thenReturn(new int[] { 6 });
// When
WebTestClient.ResponseSpec responseSpec = client
String username = "foo";
Long messageId = 66l;
when(chatHomeService.getChatRoom(anyInt(), any(UUID.class))).thenReturn(Mono.empty());
+ when(chatHomeService.getOwnedShards()).thenReturn(new int[] { 6 });
// When
WebTestClient.ResponseSpec responseSpec = client
// Given
UUID chatroomId = getRandomIdForOwnedShard();
when(chatHomeService.getChatRoom(anyInt(), any(UUID.class))).thenReturn(Mono.empty());
+ when(chatHomeService.getOwnedShards()).thenReturn(new int[] { 6 });
// When
WebTestClient.ResponseSpec responseSpec = client