}
private void handleRegistrationCompleted() {
- logger.debug("Registering types and producer completed");
isRegisteredInEcs = true;
}
private Mono<Boolean> isRegisterredInfoCorrect(String registerredInfoStr) {
ProducerRegistrationInfo registerredInfo = gson.fromJson(registerredInfoStr, ProducerRegistrationInfo.class);
if (isEqual(producerRegistrationInfo(), registerredInfo)) {
- logger.trace("Already registered");
+ logger.trace("Already registered in ECS");
return Mono.just(Boolean.TRUE);
} else {
return Mono.just(Boolean.FALSE);
// An object with no properties
String schemaStr = "{" //
+ "\"type\": \"object\"," //
- + "\"properties\": {}," //
+ + "\"properties\": {" //
+ + " \"filter\": { \"type\": \"string\" }" //
+ + "}," //
+ "\"additionalProperties\": false" //
+ "}"; //
- return jsonObject(schemaStr);
+ return
+
+ jsonObject(schemaStr);
}
+
}
private String readSchemaFile(String filePath) throws IOException, ServiceException {