@Test
  public void testFindEntriesSinceUsingUpdateTime() throws Exception {
    AzureCloudDestination updateTimeBasedAzureCloudDestination = null;
    try {
      updateTimeBasedAzureCloudDestination =
          new AzureCloudDestination(mockServiceAsyncClient, mockBlobBatchAsyncClient, mockCosmosAsyncClient,
              mockCosmosAsyncDatabase, mockCosmosAsyncContainer, "ambry", "metadata", "deletedContainer", clusterName,
              azureMetrics, AzureReplicationFeed.FeedType.COSMOS_UPDATE_TIME, clusterMap, false, configProps);
      testFindEntriesSinceWithUniqueUpdateTimes(updateTimeBasedAzureCloudDestination);
      testFindEntriesSinceWithNonUniqueUpdateTimes(updateTimeBasedAzureCloudDestination);
    } finally {
      if (updateTimeBasedAzureCloudDestination != null) {
        updateTimeBasedAzureCloudDestination.close();
      }
    }
  }
Test findEntriesSince when cloud destination uses update time based token.
ambry-cloud/src/test/java/com/github/ambry/cloud/azure/AzureCloudDestinationTest.java