public class SampleChangeFeedProcessor extends Object
Modifier and Type | Field and Description |
---|---|
static String |
COLLECTION_NAME |
static String |
DATABASE_NAME |
protected static org.slf4j.Logger |
logger |
static int |
WAIT_FOR_WORK |
Constructor and Description |
---|
SampleChangeFeedProcessor() |
Modifier and Type | Method and Description |
---|---|
static CosmosAsyncContainer |
createNewCollection(CosmosAsyncClient client,
String databaseName,
String collectionName) |
static CosmosAsyncDatabase |
createNewDatabase(CosmosAsyncClient client,
String databaseName) |
static void |
createNewDocuments(CosmosAsyncContainer containerClient,
int count,
Duration delay) |
static CosmosAsyncContainer |
createNewLeaseCollection(CosmosAsyncClient client,
String databaseName,
String leaseCollectionName) |
static void |
deleteDatabase(CosmosAsyncDatabase cosmosDatabase) |
static boolean |
ensureWorkIsDone(Duration delay) |
static ChangeFeedProcessor |
getChangeFeedProcessor(String hostName,
CosmosAsyncContainer feedContainer,
CosmosAsyncContainer leaseContainer) |
static CosmosAsyncClient |
getCosmosClient() |
static void |
main(String[] args) |
public static int WAIT_FOR_WORK
public static final String DATABASE_NAME
public static final String COLLECTION_NAME
protected static org.slf4j.Logger logger
public static void main(String[] args)
public static ChangeFeedProcessor getChangeFeedProcessor(String hostName, CosmosAsyncContainer feedContainer, CosmosAsyncContainer leaseContainer)
public static CosmosAsyncClient getCosmosClient()
public static CosmosAsyncDatabase createNewDatabase(CosmosAsyncClient client, String databaseName)
public static void deleteDatabase(CosmosAsyncDatabase cosmosDatabase)
public static CosmosAsyncContainer createNewCollection(CosmosAsyncClient client, String databaseName, String collectionName)
public static CosmosAsyncContainer createNewLeaseCollection(CosmosAsyncClient client, String databaseName, String leaseCollectionName)
public static void createNewDocuments(CosmosAsyncContainer containerClient, int count, Duration delay)
public static boolean ensureWorkIsDone(Duration delay)
Copyright © 2020 Microsoft Corporation. All rights reserved.