private void updateBlobMap(ReplicateBlobRequest replicateBlobRequest) {
    String sourceHostName = replicateBlobRequest.getSourceHostName();
    int sourceHostPort = replicateBlobRequest.getSourceHostPort();
    BlobId blobId = replicateBlobRequest.getBlobId();
    // local store has the Blob already
    if (blobs.containsKey(blobId.getID())) {
      return;
    }

    // replicating the Blob from the source Data node.
    for (MockServer server : layout.getMockServers()) {
      // find the source Data node.
      if (server.getHostName().equals(sourceHostName) && server.getHostPort().equals(sourceHostPort)) {
        Map<String, StoredBlob> remoteBlobs = server.getBlobs();
        if (remoteBlobs.containsKey(blobId.getID())) {
          // write to the local store
          this.blobs.put(blobId.getID(), remoteBlobs.get(blobId.getID()));
        }
        break;
      }
    }
  }
Serialize contents of the ReplicateBlobRequest and update the blob map with the serialized content.
@param replicateBlobRequest the ReplicateBlobRequest
ambry-router/src/test/java/com/github/ambry/router/MockServer.java