public class ChangeFeedEncryptionProcessorBuilder extends Object
ChangeFeedProcessor
instance.Constructor and Description |
---|
ChangeFeedEncryptionProcessorBuilder()
Helper class to build a encryption supported
ChangeFeedProcessor instance. |
Modifier and Type | Method and Description |
---|---|
ChangeFeedProcessor |
buildChangeFeedProcessor()
Builds a new instance of the
ChangeFeedProcessor with the specified configuration. |
ChangeFeedEncryptionProcessorBuilder |
feedContainer(CosmosEncryptionAsyncContainer feedContainer)
Sets an existing
CosmosEncryptionAsyncContainer to be used to read from the monitored container. |
ChangeFeedEncryptionProcessorBuilder |
handleChanges(Consumer<List<JsonNode>> consumer)
Sets a consumer function which will be called to process changes.
|
ChangeFeedEncryptionProcessorBuilder |
hostName(String hostName)
Sets the host name.
|
ChangeFeedEncryptionProcessorBuilder |
leaseContainer(CosmosAsyncContainer leaseContainer)
Sets an existing
CosmosAsyncContainer to be used to read from the leases container. |
ChangeFeedEncryptionProcessorBuilder |
options(ChangeFeedProcessorOptions changeFeedProcessorOptions)
Sets the
ChangeFeedProcessorOptions to be used. |
public ChangeFeedEncryptionProcessorBuilder()
ChangeFeedProcessor
instance.public ChangeFeedEncryptionProcessorBuilder hostName(String hostName)
hostName
- the name to be used for the host. When using multiple hosts, each host must have a unique
name.public ChangeFeedEncryptionProcessorBuilder feedContainer(CosmosEncryptionAsyncContainer feedContainer)
CosmosEncryptionAsyncContainer
to be used to read from the monitored container.feedContainer
- the instance of CosmosEncryptionAsyncContainer
to be used.public ChangeFeedEncryptionProcessorBuilder leaseContainer(CosmosAsyncContainer leaseContainer)
CosmosAsyncContainer
to be used to read from the leases container.leaseContainer
- the instance of CosmosAsyncContainer
to use.public ChangeFeedEncryptionProcessorBuilder handleChanges(Consumer<List<JsonNode>> consumer)
consumer
- the Consumer
to call for handling the feeds.public ChangeFeedEncryptionProcessorBuilder options(ChangeFeedProcessorOptions changeFeedProcessorOptions)
ChangeFeedProcessorOptions
to be used.
Unless specifically set the default values that will be used are:
changeFeedProcessorOptions
- the change feed processor options to use.public ChangeFeedProcessor buildChangeFeedProcessor()
ChangeFeedProcessor
with the specified configuration.ChangeFeedProcessor
.Copyright © 2021 Microsoft Corporation. All rights reserved.