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
.Visit the Azure for Java Developers site for more Java documentation, including quick starts, tutorials, and code samples.