name = "sharding-strategy",
havingValue = "none",
matchIfMissing = true)
- ChatHomeService noneShardingChatHome(
+ SimpleChatHomeService noneShardingChatHome(
ChatBackendProperties properties,
StorageStrategy storageStrategy,
Clock clock)
{
SimpleChatHomeService chatHomeService = new SimpleChatHomeService(
clock,
- properties.getChatroomBufferSize());
+ properties.getChatroomHistoryLimit());
chatHomeService.restore(storageStrategy).block();
return chatHomeService;
}
prefix = "chat.backend.inmemory",
name = "sharding-strategy",
havingValue = "kafkalike")
- ChatHomeService kafkalikeShardingChatHome(
+ ShardedChatHomeService kafkalikeShardingChatHome(
ChatBackendProperties properties,
StorageStrategy storageStrategy,
Clock clock)
SimpleChatHomeService service = chatHomes[shard] = new SimpleChatHomeService(
shard,
clock,
- properties.getChatroomBufferSize());
+ properties.getChatroomHistoryLimit());
service.restore(storageStrategy).block();
});
ShardingStrategy strategy = new KafkaLikeShardingStrategy(numShards);