in sample-app/src/main/java/co/elastic/opamp/sample/ElasticExample.java [11:37]
public static void main(String[] args) {
String serviceName = "some-service";
if (args.length > 0) {
serviceName = args[0];
}
logger.info("============= Starting client for: " + serviceName);
CentralConfigurationManager centralConfigurationManager =
CentralConfigurationManager.builder()
.setServiceName(serviceName)
.setServiceVersion("1.0.0")
.setPollingInterval(Duration.ofSeconds(5))
.build();
centralConfigurationManager.start(
configuration -> {
logger.info("Received configuration: " + configuration);
return CentralConfigurationProcessor.Result.SUCCESS;
});
Runtime.getRuntime()
.addShutdownHook(
new Thread(
() -> {
logger.info("=========== Shutting down");
centralConfigurationManager.stop();
}));
}