diff --git a/build/common.props b/build/common.props index 1deb72f6..6f789453 100644 --- a/build/common.props +++ b/build/common.props @@ -3,7 +3,7 @@ 3.0.0$(VersionSuffix) 5.0.0$(VersionSuffix) - 4.6.1$(VersionSuffix) + 4.7.0$(VersionSuffix) 3.2.0$(VersionSuffix) 3.0.0$(VersionSuffix) 3.0.3$(VersionSuffix) diff --git a/src/WebJobs.Extensions.CosmosDB/Trigger/CosmosDBTriggerHealthMonitor.cs b/src/WebJobs.Extensions.CosmosDB/Trigger/CosmosDBTriggerHealthMonitor.cs index f31f055b..faa26a60 100644 --- a/src/WebJobs.Extensions.CosmosDB/Trigger/CosmosDBTriggerHealthMonitor.cs +++ b/src/WebJobs.Extensions.CosmosDB/Trigger/CosmosDBTriggerHealthMonitor.cs @@ -59,7 +59,7 @@ public Task OnLeaseReleaseAsync(string leaseToken) public void OnChangesDelivered(ChangeFeedProcessorContext context) { - this.logger.LogDebug(Events.OnDelivery, "Events delivered to lease {LeaseToken} with diagnostics {Diagnostics}", context.LeaseToken, context.Diagnostics); + this.logger.LogDebug(Events.OnDelivery, "Events delivered to lease {LeaseToken}, Continuation {Continuation} with diagnostics {Diagnostics}", context.LeaseToken, context.Headers.ContinuationToken, context.Diagnostics); } } } diff --git a/src/WebJobs.Extensions.CosmosDB/WebJobs.Extensions.CosmosDB.csproj b/src/WebJobs.Extensions.CosmosDB/WebJobs.Extensions.CosmosDB.csproj index db2e0f30..ec18eff0 100644 --- a/src/WebJobs.Extensions.CosmosDB/WebJobs.Extensions.CosmosDB.csproj +++ b/src/WebJobs.Extensions.CosmosDB/WebJobs.Extensions.CosmosDB.csproj @@ -19,7 +19,7 @@ - + diff --git a/test/WebJobs.Extensions.CosmosDB.Tests/Trigger/CosmosDBTriggerHealthMonitorTests.cs b/test/WebJobs.Extensions.CosmosDB.Tests/Trigger/CosmosDBTriggerHealthMonitorTests.cs index 2befe08b..0a2b15ee 100644 --- a/test/WebJobs.Extensions.CosmosDB.Tests/Trigger/CosmosDBTriggerHealthMonitorTests.cs +++ b/test/WebJobs.Extensions.CosmosDB.Tests/Trigger/CosmosDBTriggerHealthMonitorTests.cs @@ -57,10 +57,13 @@ public void LogsOnChangesDelivered() string diagnosticsString = Guid.NewGuid().ToString(); Mock diagnostics = new Mock(); diagnostics.Setup(m => m.ToString()).Returns(diagnosticsString); + Headers headers = new Headers(); + string continuationValue = Guid.NewGuid().ToString(); + headers["x-ms-continuation"] = continuationValue; Mock context = new Mock(); context.Setup(m => m.LeaseToken).Returns(leaseToken); context.Setup(m => m.Diagnostics).Returns(diagnostics.Object); - + context.Setup(m => m.Headers).Returns(headers); cosmosDBTriggerHealthMonitor.OnChangesDelivered(context.Object); Assert.Single(mockedLogger.Events); @@ -68,7 +71,7 @@ public void LogsOnChangesDelivered() LogEvent loggedEvent = mockedLogger.Events[0]; Assert.Equal(LogLevel.Debug, loggedEvent.LogLevel); Assert.Null(loggedEvent.Exception); - Assert.True(loggedEvent.Message.Contains(leaseToken) && loggedEvent.Message.Contains(diagnosticsString)); + Assert.True(loggedEvent.Message.Contains(leaseToken) && loggedEvent.Message.Contains(diagnosticsString) && loggedEvent.Message.Contains(continuationValue)); } [Theory]