Merge pull request #47 from TheovanKraay/change-feed-processor-tags

add ChangeFeedProcessorOptions variable

Author: TheovanKraay

src/main/java/com/azure/cosmos/examples/changefeed/SampleChangeFeedProcessor.java

@@ -13,6 +13,7 @@
 import com.azure.cosmos.examples.common.CustomPOJO2;
 import com.azure.cosmos.implementation.Utils;
 import com.azure.cosmos.implementation.apachecommons.lang.RandomStringUtils;
+import com.azure.cosmos.models.ChangeFeedProcessorOptions;
 import com.azure.cosmos.models.CosmosContainerProperties;
 import com.azure.cosmos.models.CosmosContainerRequestOptions;
 import com.azure.cosmos.models.CosmosContainerResponse;
@@ -21,6 +22,7 @@
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import reactor.core.scheduler.Schedulers;
@@ -49,11 +51,20 @@ public class SampleChangeFeedProcessor {
     private static ChangeFeedProcessor changeFeedProcessorInstance;
     private static boolean isWorkCompleted = false;
 
+    private static ChangeFeedProcessorOptions options;
+
+
+
     public static void main(String[] args) {
         logger.info("BEGIN Sample");
 
         try {
 
+            // <ChangeFeedProcessorOptions>
+            options = new ChangeFeedProcessorOptions();            
+            options.setStartFromBeginning(false);
+            // </ChangeFeedProcessorOptions>
+
             //Summary of the next four commands:
             //-Create an asynchronous Azure Cosmos DB client and database so that we can issue async requests to the DB
             //-Create a "feed container" and a "lease container" in the DB
@@ -129,6 +140,7 @@ public static void main(String[] args) {
     public static ChangeFeedProcessor getChangeFeedProcessor(String hostName, CosmosAsyncContainer feedContainer, CosmosAsyncContainer leaseContainer) {
         return new ChangeFeedProcessorBuilder()
                 .hostName(hostName)
+                .options(options)
                 .feedContainer(feedContainer)
                 .leaseContainer(leaseContainer)
                 .handleChanges((List<JsonNode> docs) -> {