mirror of https://github.com/dapr/java-sdk.git
Update docs for configuration api (#813)
* fix docs for configuration api Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com> * Update daprdocs/content/en/java-sdk-docs/_index.md Signed-off-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com> Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com> Signed-off-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com> Co-authored-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>
This commit is contained in:
parent
bc9de9fa7e
commit
7593b0e078
|
|
@ -292,13 +292,16 @@ try (DaprPreviewClient client = (new DaprClientBuilder()).buildPreviewClient())
|
|||
// Get configuration for a single key
|
||||
Mono<ConfigurationItem> item = client.getConfiguration(CONFIG_STORE_NAME, CONFIG_KEY).block();
|
||||
|
||||
// Get Configurations for multiple keys
|
||||
Mono<List<ConfigurationItem>> items =
|
||||
// Get configurations for multiple keys
|
||||
Mono<Map<String, ConfigurationItem>> items =
|
||||
client.getConfiguration(CONFIG_STORE_NAME, CONFIG_KEY_1, CONFIG_KEY_2);
|
||||
|
||||
// Susbcribe to Confifuration changes
|
||||
Flux<List<ConfigurationItem>> outFlux = client.subscribeToConfiguration(CONFIG_STORE_NAME, CONFIG_KEY_1, CONFIG_KEY_2);
|
||||
// Subscribe to configuration changes
|
||||
Flux<SubscribeConfigurationResponse> outFlux = client.subscribeConfiguration(CONFIG_STORE_NAME, CONFIG_KEY_1, CONFIG_KEY_2);
|
||||
outFlux.subscribe(configItems -> configItems.forEach(...));
|
||||
|
||||
// Unsubscribe from configuration changes
|
||||
Mono<UnsubscribeConfigurationResponse> unsubscribe = client.unsubscribeConfiguration(SUBSCRIPTION_ID, CONFIG_STORE_NAME)
|
||||
}
|
||||
```
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue