¿Qué permitió aumentar la capacidad de la servicio de replicación de aproximadamente 300 a 700 mensajes por segundo? ¿Cómo se usaron ConcurrentDictionary y SemaphoreSlim?