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 and Description
protected EntityFactory	entityFactory
protected JobStatusDAO	jobStatusDAO
protected static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
JobStatusUpdater()

Method Summary

Modifier and Type	Method and Description
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 Detail

LOG

protected static final org.slf4j.Logger LOG

jobStatusDAO

@Autowired
protected JobStatusDAO jobStatusDAO

entityFactory

@Autowired
protected EntityFactory entityFactory

Constructor Detail

JobStatusUpdater

public JobStatusUpdater()

Method Detail

update

@Async(value="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