synchronized void removeMissingStoreMessages(Set<MessageInfo> messagesWrittenToStore) {
      if (missingStoreMessages != null && receivedStoreMessagesWithUpdatesPending != null) {
        boolean missingMessagesReceived = false;
        for (MessageInfo messageToRemove : messagesWrittenToStore) {
          if (missingStoreMessages.remove(messageToRemove)) {
            receivedStoreMessagesWithUpdatesPending.add(messageToRemove);
            missingMessagesReceived = true;
          }
        }
        if (missingMessagesReceived) {
          lastMissingMessageReceivedTimeSec = time.seconds();
        }
      }
    }
Removes missing store messages (who blobs are now written to local store) from 'missingStoreMessages' set and
adds them to 'receivedStoreMessagesWithUpdatesPending' set. Replica threads will go through
receivedStoreMessagesWithUpdatesPending set and compare message info of these remote messages with message info
of matching blobs in local store to reconcile blob properties ttl_update/delete/undelete.
@param messagesWrittenToStore messages that needs to be removed from missingStoreMessages set and added to
                    receivedStoreMessagesWithUpdatesPending.
ambry-replication/src/main/java/com/github/ambry/replication/ReplicaThread.java