public List create()

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