Package org.neotropic.kuwaiba.modules.commercial.sync

Class JobService

java.lang.Object

org.neotropic.kuwaiba.modules.commercial.sync.JobService

@Service
public class JobService
extends Object

The service creates asynchronous jobs to obtain and deliver information about a synchronization process.

Author:

Hardy Ryan Chingal Martinez <ryan.chingal@neotropic.co>

Constructor Summary

Constructors

Constructor	Description
JobService()

Method Summary

Modifier and Type	Method	Description
CompletableFuture<List<SyncResult>>	createAsyncActionsJob(PollResult pollResult, AbstractSyncProvider syncProvider, int totalElements, int currentElement)	Asynchronous thread to obtain the results of the previous data collection process.
CompletableFuture<PollResult>	createAsyncFetchJob(AbstractSyncProvider syncProvider, SyncDataSourceConfiguration dataSourceConfiguration)	Async thread to fetch data using a data source configuration
CompletableFuture<List<SyncResult>>	createJob(AbstractSyncProvider syncProvider, List<SyncDataSourceConfiguration> datasources)	Create a thread to execute a result capture to be sent to the user in a dialog.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JobService

public JobService()

Method Detail

createAsyncFetchJob

@Async
public CompletableFuture<PollResult> createAsyncFetchJob(AbstractSyncProvider syncProvider,
                                                         SyncDataSourceConfiguration dataSourceConfiguration)

Async thread to fetch data using a data source configuration

Parameters:

syncProvider - synchronization provider

dataSourceConfiguration - data source configuration

Returns:

completale future thread

createAsyncActionsJob

@Async
public CompletableFuture<List<SyncResult>> createAsyncActionsJob(PollResult pollResult,
                                                                 AbstractSyncProvider syncProvider,
                                                                 int totalElements,
                                                                 int currentElement)

Asynchronous thread to obtain the results of the previous data collection process.

Parameters:

pollResult - results of data collection process

syncProvider - synchronization provider

totalElements - total jobs

currentElement - current job

Returns:

completale future thread

createJob

public CompletableFuture<List<SyncResult>> createJob(AbstractSyncProvider syncProvider,
                                                     List<SyncDataSourceConfiguration> datasources)
                                              throws InterruptedException

Create a thread to execute a result capture to be sent to the user in a dialog.

Parameters:

syncProvider - synchronization provider

datasources - data soruce sonfiguration

Returns:

completale future thread

Throws:

InterruptedException