Skip to content

Commit 2a7e356

Browse files
author
Theo van Kraay
committed
add options.setLeasePrefix
1 parent ae1fd25 commit 2a7e356

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,7 @@ public static void main(String[] args) {
6363
// <ChangeFeedProcessorOptions>
6464
options = new ChangeFeedProcessorOptions();
6565
options.setStartFromBeginning(false);
66+
options.setLeasePrefix("myChangeFeedDeploymentUnit");
6667
// </ChangeFeedProcessorOptions>
6768

6869
//Summary of the next four commands:
@@ -125,7 +126,7 @@ public static void main(String[] args) {
125126
}
126127

127128
logger.info("-->DELETE sample's database: " + DATABASE_NAME);
128-
deleteDatabase(cosmosDatabase);
129+
//deleteDatabase(cosmosDatabase);
129130

130131
Thread.sleep(500);
131132

0 commit comments

Comments
 (0)