Package org.apache.syncope.core.provisioning.java.job

Class JobStatusUpdater

java.lang.Object

org.apache.syncope.core.provisioning.java.job.JobStatusUpdater

public class JobStatusUpdater
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final EntityFactory	entityFactory
protected boolean	initCompleted
protected final JobStatusDAO	jobStatusDAO
protected static final Logger	LOG

Constructor Summary

Constructors

Constructor	Description
JobStatusUpdater(JobStatusDAO jobStatusDAO, EntityFactory entityFactory)

Method Summary

Modifier and Type	Method	Description
void	initComplete()
void	update(JobStatusEvent event)	It's important to note that responding to job status updates must be done in async mode, and via a separate special thread executor that attempts to synchronize job execution serially by only making one thread active at a given time.

Methods inherited from class java.lang.Object

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

Field Details

LOG

protected static final Logger LOG

jobStatusDAO

protected final JobStatusDAO jobStatusDAO

entityFactory

protected final EntityFactory entityFactory

initCompleted

protected boolean initCompleted

Constructor Details

JobStatusUpdater

public JobStatusUpdater(JobStatusDAO jobStatusDAO,
 EntityFactory entityFactory)

Method Details

initComplete

public void initComplete()

update

@Async("jobStatusUpdaterThreadExecutor")
@EventListener
public void update(JobStatusEvent event)

It's important to note that responding to job status updates must be done in async mode, and via a separate special thread executor that attempts to synchronize job execution serially by only making one thread active at a given time. Not doing so will force the event executor to launch separate threads per each status update, which would result in multiple concurrent INSERT operations on the database, and failing.

Parameters:

event - the event