public List create()

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());
  }