private void verifyReplicateBlobRequest(ReplicateBlobRequest orgReq, ReplicateBlobRequest deserializedReq) {
    Assert.assertEquals(orgReq.getCorrelationId(), deserializedReq.getCorrelationId());
    Assert.assertEquals(orgReq.getAccountId(), deserializedReq.getAccountId());
    Assert.assertEquals(orgReq.getContainerId(), deserializedReq.getContainerId());
    Assert.assertEquals(orgReq.getClientId(), deserializedReq.getClientId());
    Assert.assertEquals(orgReq.getBlobId(), deserializedReq.getBlobId());
    Assert.assertEquals(orgReq.getSourceHostName(), deserializedReq.getSourceHostName());
    Assert.assertEquals(orgReq.getSourceHostPort(), deserializedReq.getSourceHostPort());

    if (orgReq.versionId == ReplicateBlobRequest.VERSION_1) {
      Assert.assertEquals(RequestOrResponseType.PutRequest, deserializedReq.getOperationType());
      Assert.assertEquals(0, deserializedReq.getOperationTimeInMs());
      Assert.assertEquals(-1, deserializedReq.getLifeVersion());
      Assert.assertEquals(0, deserializedReq.getExpirationTimeInMs());
    } else {
      Assert.assertEquals(orgReq.getOperationType(), deserializedReq.getOperationType());
      Assert.assertEquals(orgReq.getOperationTimeInMs(), deserializedReq.getOperationTimeInMs());
      Assert.assertEquals(orgReq.getLifeVersion(), deserializedReq.getLifeVersion());
      Assert.assertEquals(orgReq.getExpirationTimeInMs(), deserializedReq.getExpirationTimeInMs());
    }
  }
Verify the two {@link ReplicateBlobRequest} are the same
@param orgReq the original {@link ReplicateBlobRequest}
@param deserializedReq the deserialized {@link ReplicateBlobRequest}
ambry-protocol/src/test/java/com/github/ambry/protocol/RequestResponseTest.java