in src/main/java/com/epam/digital/data/platform/generator/factory/impl/nested/NestedListenerScopeFactory.java [42:65]
public List<ListenerScope> create(Context context) {
return nestedStructureProvider.findAll().stream()
.map(
nestedStructure -> {
var tableName = nestedStructure.getRoot().getTableName();
var schemaName = getSchemaName(nestedStructure.getName(), tableName) + "Nested";
var scope = new ListenerScope();
scope.setClassName(schemaName + "UpsertListener");
scope.setSchemaName(schemaName);
var rootOfTopicName =
toHyphenTableName(nestedStructure.getName())
+ "-"
+ toHyphenTableName(nestedStructure.getRoot().getTableName())
+ "-nested";
scope.setRootOfTopicName(rootOfTopicName);
scope.setOperation("upsert");
scope.setOutputType(UPSERT_OUTPUT_TYPE);
scope.setHandlerName(schemaName + "UpsertCommandHandler");
return scope;
})
.collect(toList());
}