systemHelper = new SystemHelper() {
            @Override
            public long getCurrentTimeAsLong() {
                return System.currentTimeMillis();
            }
        };
        ComponentUtil.register(systemHelper, "systemHelper");

        // Create temporary directory for test JAR files
        tempDir = Files.createTempDirectory("datastore-test").toFile();
        tempDir.deleteOnExit();
    }

    @Override

     * @param form the search form containing current search criteria
     */
    protected void searchPaging(final RenderData data, final SearchForm form) {
        RenderDataUtil.register(data, "scheduledJobItems", scheduledJobService.getScheduledJobList(schedulerPager)); // page navi

        // restore from pager
        copyBeanToBean(schedulerPager, form, op -> op.include("id"));
    }

     * @param form The search form containing criteria
     */
    protected void searchPaging(final RenderData data, final SearchForm form) {
        // page navi
        RenderDataUtil.register(data, "stemmerOverrideItemItems",
                stemmerOverrideService.getStemmerOverrideList(form.dictId, stemmerOverridePager));

        // restore from pager

   * it can fail here.
   */
  public void testAnonymous() {
    AtomicReference<String> holder = new AtomicReference<>();
    AtomicInteger deliveries = new AtomicInteger();
    EventBus bus = new EventBus();
    bus.register(
        new Object() {
          @Subscribe
          public void accept(String str) {
            holder.set(str);
            deliveries.incrementAndGet();
          }
        });

                    }
                }
                return count;
            }
        };

        final FessConfig fessConfig = new TestFessConfig(tempDir.toString(), "cache", "100");
        ComponentUtil.register(searchEngineClient, "searchEngineClient");
        ComponentUtil.setFessConfig(fessConfig);
    }

    // --- query() tests ---

    @Test
    public void test_query_returnsThis() {

 */
public class IngestFactory {
    /** Logger instance for this class */
    private static final Logger logger = LogManager.getLogger(IngestFactory.class);

    /** Array of registered ingesters, sorted by priority */
    private Ingester[] ingesters = {};

    /**
     * Default constructor.
     */
    public IngestFactory() {
        // Default constructor
    }

    /**

    public static final String TASK_NAME = "splitPackagesAudit";

    @Override
    public TaskProvider<? extends Task> createTask(Project project) {
        TaskProvider<SplitPackagesAuditTask> task = project.getTasks().register(TASK_NAME, SplitPackagesAuditTask.class);
        task.configure(t -> {
            t.setClasspath(project.getConfigurations().getByName(JavaPlugin.COMPILE_CLASSPATH_CONFIGURATION_NAME));

    @Override
    public TaskProvider<? extends Task> createTask(Project project) {
        TaskProvider<TestingConventionsTasks> testingConventions = project.getTasks()
            .register("testingConventions", TestingConventionsTasks.class);
        testingConventions.configure(t -> {
            TestingConventionRule testsRule = t.getNaming().maybeCreate("Tests");

//     that gets offloaded). The same registry key setting overwrites the storage-defined setting.
//     Optional value, default 64, range: 1-unlimited
//
//   - <S3MultiObjectDeleteLimit>
//     Some of the Veeam products use Multi Delete operations. This setting can reduce how many objects are included in one
//     multi-delete operation. The same registry key setting overwrites the storage-defined setting.

     * @param data The render data.
     * @param form The search form.
     */
    protected void searchPaging(final RenderData data, final SearchForm form) {
        // page navi
        RenderDataUtil.register(data, "protwordsItemItems", protwordsService.getProtwordsList(form.dictId, protwordsPager));

        // restore from pager
        BeanUtil.copyBeanToBean(protwordsPager, form, op -> {