Package de.hybris.platform.sap.productconfig.model.cronjob

Class DataLoaderJob

java.lang.Object

de.hybris.platform.servicelayer.cronjob.AbstractJobPerformable<DataLoaderCronJobModel>

de.hybris.platform.sap.productconfig.model.cronjob.DataLoaderJob

All Implemented Interfaces:

JobPerformable<DataLoaderCronJobModel>

public class DataLoaderJob
extends AbstractJobPerformable<DataLoaderCronJobModel>

Performs initial and delta load

Field Summary

Fields inherited from class de.hybris.platform.servicelayer.cronjob.AbstractJobPerformable

flexibleSearchService, modelService, sessionService

Constructor Summary

Constructors

Constructor	Description
DataLoaderJob()

Method Summary

Modifier and Type	Method	Description
protected PerformResult	checkForResume(DataLoaderCronJobModel dataLoaderCronJobModel, DataLoadTriggerMode triggerMode)
protected com.sap.custdev.projects.fbs.slc.dataloader.standalone.manager.DataloaderManager	createDataloaderManager(com.sap.custdev.projects.fbs.slc.dataloader.settings.IDataloaderConfiguration dataloaderConfiguration)
CronJobService	getCronJobService()
DataLoaderConfigurationHelper	getDataLoaderConfigurationHelper()
DataLoaderManagerContainer	getDataLoaderManagerContainer()
DefaultDataloaderMessageListenerImpl	getMessageListener()
protected ModelService	getModelService()
DefaultDataloaderProgressListenerImpl	getProgressListener()
PropertyAccessFacade	getPropertyAccessFacade()
protected com.sap.custdev.projects.fbs.slc.dataloader.standalone.manager.DataloaderManager	initializeDataLoaderManager(DataLoaderCronJobModel dataLoaderCronJobModel)
protected boolean	isAbortNeeded(DataLoaderCronJobModel dataLoaderCronJobModel)
protected boolean	isDeltaLoadStartAllowed(SAPConfigurationModel sapConfiguration)
protected boolean	isResumePerformed()
PerformResult	perform(DataLoaderCronJobModel dataLoaderCronJobModel)	The execution body for a ServicelayerJob.
protected com.sap.custdev.projects.fbs.slc.dataloader.standalone.manager.DataloaderManager	prepareDataloadManager(DataLoaderCronJobModel dataLoaderCronJobModel)
void	setCronJobService(CronJobService cronJobService)
void	setDataLoader(DataLoader dataLoader)
void	setDataLoaderConfigurationHelper(DataLoaderConfigurationHelper dataLoaderConfigurationHelper)	Set configuration helper
void	setDataLoaderManagerContainer(DataLoaderManagerContainer dataLoaderManagerContainer)
void	setMessageListener(DefaultDataloaderMessageListenerImpl messageListener)	Sets message listener
void	setProgressListener(DefaultDataloaderProgressListenerImpl progressListener)	Sets progress listener
void	setPropertyAccessFacade(PropertyAccessFacade propertyAccessFacade)
protected PerformResult	startDeltaLoad(DataLoadTriggerMode triggerMode, SAPConfigurationModel sapConfiguration, com.sap.custdev.projects.fbs.slc.dataloader.standalone.manager.DataloaderManager dataloaderManager)	Tries to start delta load

Methods inherited from class de.hybris.platform.servicelayer.cronjob.AbstractJobPerformable

clearAbortRequestedIfNeeded, isAbortable, isPerformable, setFlexibleSearchService, setModelService, setSessionService

Methods inherited from class java.lang.Object

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

Constructor Detail

DataLoaderJob

public DataLoaderJob()

Method Detail

getPropertyAccessFacade

public PropertyAccessFacade getPropertyAccessFacade()

Returns:

the propertyAccessFacade

getMessageListener

public DefaultDataloaderMessageListenerImpl getMessageListener()

Returns:

the messageListener

getProgressListener

public DefaultDataloaderProgressListenerImpl getProgressListener()

Returns:

the progressListener

perform

public PerformResult perform(DataLoaderCronJobModel dataLoaderCronJobModel)

Description copied from interface: JobPerformable

The execution body for a ServicelayerJob. Implement here your execution logic. It can be called synchronous or asynchronous. So be aware of thread-safety. Method will return a result object saying if the execution has reached end and if it was successful.

Specified by:

perform in interface JobPerformable<DataLoaderCronJobModel>

Specified by:

perform in class AbstractJobPerformable<DataLoaderCronJobModel>

Parameters:

dataLoaderCronJobModel - the related CronJob in whose context the execution will be performed.

Returns:

a PerformResult that indicates whether the execution was successfully executed or not and has finished or not.

startDeltaLoad

protected PerformResult startDeltaLoad(DataLoadTriggerMode triggerMode,
                                       SAPConfigurationModel sapConfiguration,
                                       com.sap.custdev.projects.fbs.slc.dataloader.standalone.manager.DataloaderManager dataloaderManager)

Tries to start delta load

Parameters:

triggerMode - resume or startdelta, in other cases we throw an exception

sapConfiguration -

dataloaderManager -

Returns:

Result of load call

checkForResume

protected PerformResult checkForResume(DataLoaderCronJobModel dataLoaderCronJobModel,
                                       DataLoadTriggerMode triggerMode)

isDeltaLoadStartAllowed

protected boolean isDeltaLoadStartAllowed(SAPConfigurationModel sapConfiguration)

initializeDataLoaderManager

protected com.sap.custdev.projects.fbs.slc.dataloader.standalone.manager.DataloaderManager initializeDataLoaderManager(DataLoaderCronJobModel dataLoaderCronJobModel)

isAbortNeeded

protected boolean isAbortNeeded(DataLoaderCronJobModel dataLoaderCronJobModel)

prepareDataloadManager

protected com.sap.custdev.projects.fbs.slc.dataloader.standalone.manager.DataloaderManager prepareDataloadManager(DataLoaderCronJobModel dataLoaderCronJobModel)

createDataloaderManager

protected com.sap.custdev.projects.fbs.slc.dataloader.standalone.manager.DataloaderManager createDataloaderManager(com.sap.custdev.projects.fbs.slc.dataloader.settings.IDataloaderConfiguration dataloaderConfiguration)

getDataLoaderManagerContainer

public DataLoaderManagerContainer getDataLoaderManagerContainer()

Returns:

the dataLoaderManagerContainer

setDataLoaderManagerContainer

public void setDataLoaderManagerContainer(DataLoaderManagerContainer dataLoaderManagerContainer)

Parameters:

dataLoaderManagerContainer - the dataLoaderManagerContainer to set

getCronJobService

public CronJobService getCronJobService()

Returns:

the cronJobService

setCronJobService

public void setCronJobService(CronJobService cronJobService)

Parameters:

cronJobService -

getModelService

protected ModelService getModelService()

setProgressListener

public void setProgressListener(DefaultDataloaderProgressListenerImpl progressListener)

Sets progress listener

Parameters:

progressListener -

setMessageListener

public void setMessageListener(DefaultDataloaderMessageListenerImpl messageListener)

Sets message listener

Parameters:

messageListener -

setPropertyAccessFacade

public void setPropertyAccessFacade(PropertyAccessFacade propertyAccessFacade)

Parameters:

propertyAccessFacade -

isResumePerformed

protected boolean isResumePerformed()

setDataLoader

public void setDataLoader(DataLoader dataLoader)

Parameters:

dataLoader -

getDataLoaderConfigurationHelper

public DataLoaderConfigurationHelper getDataLoaderConfigurationHelper()

Returns:

Configuration helper

setDataLoaderConfigurationHelper

public void setDataLoaderConfigurationHelper(DataLoaderConfigurationHelper dataLoaderConfigurationHelper)

Set configuration helper

Parameters:

dataLoaderConfigurationHelper -