From 0346aa1c8f86005d643b85175c518550c6a9df9d Mon Sep 17 00:00:00 2001 From: Andrew S Date: Mon, 18 Jun 2018 17:27:45 +0100 Subject: [PATCH] Updated processor settings based on change feed options. --- .../FeedProcessing/PartitionProcessorFactory.cs | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/src/DocumentDB.ChangeFeedProcessor/FeedProcessing/PartitionProcessorFactory.cs b/src/DocumentDB.ChangeFeedProcessor/FeedProcessing/PartitionProcessorFactory.cs index 71cf64f..06cdfbb 100644 --- a/src/DocumentDB.ChangeFeedProcessor/FeedProcessing/PartitionProcessorFactory.cs +++ b/src/DocumentDB.ChangeFeedProcessor/FeedProcessing/PartitionProcessorFactory.cs @@ -37,9 +37,7 @@ public IPartitionProcessor Create(ILease lease, IChangeFeedObserver observer) var settings = new ProcessorSettings { CollectionSelfLink = this.collectionSelfLink, - RequestContinuation = !string.IsNullOrEmpty(lease.ContinuationToken) ? - lease.ContinuationToken : - this.changeFeedProcessorOptions.RequestContinuation, + RequestContinuation = this.changeFeedProcessorOptions.StartFromBeginning ? "0" : lease.ContinuationToken, PartitionKeyRangeId = lease.PartitionId, FeedPollDelay = this.changeFeedProcessorOptions.FeedPollDelay, MaxItemCount = this.changeFeedProcessorOptions.MaxItemCount,