private void checkBlobId(String blobId, BlobProperties properties, String operationName) throws IOException {
    Assert.assertNotNull("Null blobId for operation: " + operationName, blobId);
    BlobId id = new BlobId(blobId, clusterMap);
    String partitionClass = MockClusterMap.DEFAULT_PARTITION_CLASS;
    Account account = accountService.getAccountById(properties.getAccountId());
    if (account != null) {
      Container container = account.getContainerById(properties.getContainerId());
      if (container != null && container.getReplicationPolicy() != null) {
        partitionClass = container.getReplicationPolicy();
      }
    }
    Assert.assertTrue("Partition that blob was put not as required by container",
        clusterMap.getWritablePartitionIds(partitionClass).contains(id.getPartition()));
  }
Check for blob ID validity.
@param blobId the blobId
@param properties the blob properties associated with the blob (to check that the blob was put in the right
                  partition)
@param operationName a name for the operation being checked
ambry-server/src/integration-test/java/com/github/ambry/server/RouterServerTestFramework.java