.of(ownedShards())
.forEach(shard -> chatHomes[shard] = new SimpleChatHome(
shard,
- storageStrategy.read(),
+ storageStrategy,
clock,
bufferSize()));
{
return new FilesStorageStrategy(
Paths.get("target", "test-classes", "data", "files"),
- clock,
- bufferSize(),
new KafkaLikeShardingStrategy(NUM_SHARDS),
- messageFlux -> new InMemoryChatRoomService(messageFlux),
new ObjectMapper());
}