in src/main/java/com/epam/digital/data/platform/generator/factory/impl/PartialUpdateListenerScopeFactory.java [40:59]
public List<ListenerScope> create(Context context) {
return provider.findAll().stream()
.map(upd -> {
var table = findTable(upd.getTableName(), context);
var schemaName = getSchemaName(table, upd.getName());
var rootOfTopicName = toHyphenTableName(table) + "-" + toHyphenTableName(upd.getName());
var scope = new ListenerScope();
scope.setClassName(schemaName + "Listener");
scope.setSchemaName(schemaName);
scope.setPkType(getPkTypeName(table));
scope.setOperation("update");
scope.setRootOfTopicName(rootOfTopicName);
scope.setOutputType("Void");
scope.setHandlerName(schemaName + "CommandHandler");
return scope;
})
.collect(toList());
}