in src/main/java/com/epam/digital/data/platform/generator/factory/impl/CreateListCommandListenerScopeFactory.java [40:59]
public List<ListenerScope> create(Context context) {
return bulkLoadInfoProvider.getTablesWithBulkLoad().stream()
.map(
tableName -> {
var table = findTable(tableName, context);
var schemaName = getSchemaName(table) + "CreateList";
var scope = new ListenerScope();
scope.setClassName(schemaName + "Listener");
scope.setSchemaName(schemaName);
scope.setOperation("create-list");
scope.setRootOfTopicName(toHyphenTableName(table));
scope.setOutputType(
"java.util.List<com.epam.digital.data.platform.model.core.kafka.EntityId>");
scope.setHandlerName(schemaName + "CommandHandler");
return scope;
})
.collect(toList());
}