{
SimpleChatHomeService chatHomeService = new SimpleChatHomeService(
clock,
- properties.getChatroomBufferSize());
+ properties.getChatroomHistoryLimit());
chatHomeService.restore(storageStrategy).block();
return chatHomeService;
}
SimpleChatHomeService service = chatHomes[shard] = new SimpleChatHomeService(
shard,
clock,
- properties.getChatroomBufferSize());
+ properties.getChatroomHistoryLimit());
service.restore(storageStrategy).block();
});
ShardingStrategy strategy = new KafkaLikeShardingStrategy(numShards);