From 8fdf6f8fb98b09e5867948dde746bae804e29b43 Mon Sep 17 00:00:00 2001 From: Melanie Date: Wed, 8 Jul 2020 10:24:39 +0800 Subject: [PATCH] Fix the issue of ChangeFeedProcessorCodeSnippet --- .../cosmos/ChangeFeedProcessorCodeSnippet.java | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) diff --git a/sdk/cosmos/azure-cosmos/src/samples/java/com/azure/cosmos/ChangeFeedProcessorCodeSnippet.java b/sdk/cosmos/azure-cosmos/src/samples/java/com/azure/cosmos/ChangeFeedProcessorCodeSnippet.java index 1e1d7a923467..24b3e2fec460 100644 --- a/sdk/cosmos/azure-cosmos/src/samples/java/com/azure/cosmos/ChangeFeedProcessorCodeSnippet.java +++ b/sdk/cosmos/azure-cosmos/src/samples/java/com/azure/cosmos/ChangeFeedProcessorCodeSnippet.java @@ -2,6 +2,7 @@ // Licensed under the MIT License. package com.azure.cosmos; +import com.azure.cosmos.implementation.TestConfigurations; import com.fasterxml.jackson.databind.JsonNode; /** @@ -11,7 +12,12 @@ public class ChangeFeedProcessorCodeSnippet { public void changeFeedProcessorBuilderCodeSnippet() { String hostName = "test-host-name"; - CosmosAsyncClient cosmosAsyncClient = new CosmosClientBuilder().buildAsyncClient(); + CosmosAsyncClient cosmosAsyncClient = new CosmosClientBuilder() + .endpoint(TestConfigurations.HOST) + .key(TestConfigurations.MASTER_KEY) + .contentResponseOnWriteEnabled(true) + .consistencyLevel(ConsistencyLevel.SESSION) + .buildAsyncClient(); CosmosAsyncDatabase cosmosAsyncDatabase = cosmosAsyncClient.getDatabase("testDb"); CosmosAsyncContainer feedContainer = cosmosAsyncDatabase.getContainer("feedContainer"); CosmosAsyncContainer leaseContainer = cosmosAsyncDatabase.getContainer("leaseContainer"); @@ -31,7 +37,12 @@ public void changeFeedProcessorBuilderCodeSnippet() { public void handleChangesCodeSnippet() { String hostName = "test-host-name"; - CosmosAsyncClient cosmosAsyncClient = new CosmosClientBuilder().buildAsyncClient(); + CosmosAsyncClient cosmosAsyncClient = new CosmosClientBuilder() + .endpoint(TestConfigurations.HOST) + .key(TestConfigurations.MASTER_KEY) + .contentResponseOnWriteEnabled(true) + .consistencyLevel(ConsistencyLevel.SESSION) + .buildAsyncClient(); CosmosAsyncDatabase cosmosAsyncDatabase = cosmosAsyncClient.getDatabase("testDb"); CosmosAsyncContainer feedContainer = cosmosAsyncDatabase.getContainer("feedContainer"); CosmosAsyncContainer leaseContainer = cosmosAsyncDatabase.getContainer("leaseContainer");