Because most services and collectors deployed on DCAE platform relies on similar microservices a commmon Software Development Kit has been created. It contains utilities and clients which may be used when getting configuration from CBS, consuming messages from DMaaP, interacting with AAI, etc. SDK is written in Java.
...
You can use CbsClientFactory to lookup for CBS in your application. Returned CbsClient can then be used to get a configuration, poll for configuration or poll for configuration changes.
Sample usage:
| Code Block | ||
|---|---|---|
| ||
// Generate RequestID and InvocationID which will be used when logging and in HTTP requests |
...
RequestDiagnosticContext diagnosticContext = RequestDiagnosticContext.create(); |
...
// Read necessary properties from the environment |
...
final EnvProperties env = EnvProperties.fromEnvironment(); |
...
// Create the client and use it to get the configuration |
...
CbsClientFactory.createCbsClient(env) |
...
.flatMap(cbsClient -> cbsClient.get(diagnosticContext)) |
...
.subscribe(jsonObject -> { |
...
// do a stuff with your JSON configuration using GSON API |
...
final int port = Integer.parseInt(jsonObject.get("collector.listen_port").getAsString()); |
...
// ... |
...
}); |
Notes about reactive programming
...