in sample-app/src/main/java/co/elastic/opamp/sample/GenericExample.java [17:47]
public static void main(String[] args) {
OpampClient client =
createWebsocketBuilder()
.enableRemoteConfig()
.enableEffectiveConfigReporting()
.setEffectiveConfigState(new MyEffectiveConfigState())
.build();
client.start(
new OpampClient.Callback() {
@Override
public void onConnect(OpampClient client) {
logger.info("Client connected");
}
@Override
public void onConnectFailed(OpampClient client, Throwable throwable) {
logger.info("Client connect failed: " + throwable);
}
@Override
public void onErrorResponse(OpampClient client, Opamp.ServerErrorResponse errorResponse) {
logger.info("Server error: " + errorResponse);
}
@Override
public void onMessage(OpampClient client, MessageData messageData) {
logger.info("Message received: " + messageData);
}
});
}