O que permitiu aumentar a capacidade do serviço de replicação de cerca de 300 para 700 mensagens por segundo? Como foram utilizados ConcurrentDictionary e SemaphoreSlim?