With issue #3110, ReplicationCheckpoints will be validated and sent for processing by onNewCheckpoint(). But if a new checkpoint is received to replica shard while previous checkpoint is in progress, the new checkpoint should be replayed after processing current checkpoint. This implementation is not present currently.

The scope of this issue is to:

1. Store Latest received checkpoints for every replica shard.
2. Implement an Async task that will replay onNewCheckpoint() on a replica shard, whenever new checkpoint is received.