@Test public void should_take_bulk_size_from_configuration_if_null_in_step() { ProcessStep step = getStep(DistributionKind.LIST_IN_FILE, "", null); Integer bulkSize = processDistributor.findBulkSize(step.getDistribution()); assertThat(bulkSize).isEqualTo(1); }
@VisibleForTesting Integer findBulkSize(Distribution distribution) { return firstNonNull(distribution.getBulkSize(), VitamConfiguration.getWorkerBulkSize()); }
ProcessDistributorImpl implements ProcessDistributor { @VisibleForTesting Integer findBulkSize(Distribution distribution) { return firstNonNull(distribution.getBulkSize(), VitamConfiguration.getWorkerBulkSize()); } }
ProcessDistributorImpl implements ProcessDistributor { @VisibleForTesting Integer findBulkSize(Distribution distribution) { return firstNonNull(distribution.getBulkSize(), VitamConfiguration.getWorkerBulkSize()); } ProcessDistributorImpl(IWorkerManager workerManager, ServerConfiguration serverConfiguration); @VisibleForTesting  ProcessDistributorImpl(IWorkerManager workerManager, ServerConfiguration serverConfiguration,
        ProcessDataManagement processDataManagement, WorkspaceClientFactory workspaceClientFactory,
        MetaDataClientFactory metaDataClientFactory, WorkerClientFactory workerClientFactory); }
ProcessDistributorImpl implements ProcessDistributor { @VisibleForTesting Integer findBulkSize(Distribution distribution) { return firstNonNull(distribution.getBulkSize(), VitamConfiguration.getWorkerBulkSize()); } ProcessDistributorImpl(IWorkerManager workerManager, ServerConfiguration serverConfiguration); @VisibleForTesting  ProcessDistributorImpl(IWorkerManager workerManager, ServerConfiguration serverConfiguration,
        ProcessDataManagement processDataManagement, WorkspaceClientFactory workspaceClientFactory,
        MetaDataClientFactory metaDataClientFactory, WorkerClientFactory workerClientFactory); @Override ItemStatus distribute(WorkerParameters workParams, Step step, String operationId,
        PauseRecover pauseRecover); @Override ProcessDataManagement getProcessDataManagement(); }
ProcessDistributorImpl implements ProcessDistributor { @VisibleForTesting Integer findBulkSize(Distribution distribution) { return firstNonNull(distribution.getBulkSize(), VitamConfiguration.getWorkerBulkSize()); } ProcessDistributorImpl(IWorkerManager workerManager, ServerConfiguration serverConfiguration); @VisibleForTesting  ProcessDistributorImpl(IWorkerManager workerManager, ServerConfiguration serverConfiguration,
        ProcessDataManagement processDataManagement, WorkspaceClientFactory workspaceClientFactory,
        MetaDataClientFactory metaDataClientFactory, WorkerClientFactory workerClientFactory); @Override ItemStatus distribute(WorkerParameters workParams, Step step, String operationId,
        PauseRecover pauseRecover); @Override ProcessDataManagement getProcessDataManagement();  }