org.nuxeo.ecm.core.scheduler

Class SchedulerServiceImpl

java.lang.Object

org.nuxeo.runtime.model.DefaultComponent

org.nuxeo.ecm.core.scheduler.SchedulerServiceImpl

All Implemented Interfaces:

SchedulerService, Adaptable, Component, Extensible, RuntimeServiceListener, TimestampedService

public class SchedulerServiceImpl
extends DefaultComponent
implements SchedulerService, RuntimeServiceListener

Schedule service implementation. Since the cleanup of the quartz job is done when service is activated, ( see see https://jira.nuxeo.com/browse/NXP-7303 ) in cluster mode, the schedules contributions MUST be the same on all nodes. Due the fact that all jobs are removed when service starts on a node it may be a short period with no schedules in quartz table even other node is running.

Field Summary

Fields

Modifier and Type	Field and Description
protected RuntimeContext	context
protected ScheduleExtensionRegistry	registry
protected org.quartz.Scheduler	scheduler

Fields inherited from class org.nuxeo.runtime.model.DefaultComponent

lastModified

Constructor Summary

Constructors

Constructor and Description
SchedulerServiceImpl()

Method Summary

Modifier and Type	Method and Description
void	activate(ComponentContext context) Activates the component.
void	applicationStarted(ComponentContext context) Notify the component that Nuxeo Framework finished starting all Nuxeo bundles.
void	deactivate(ComponentContext context) Deactivates the component.
RuntimeContext	getContext()
void	handleEvent(RuntimeServiceEvent event)
boolean	hasApplicationStarted() Checks if the framework has fully started.
void	registerExtension(Extension extension) Registers the given extension.
void	registerSchedule(Schedule schedule) Registers a schedule.
void	registerSchedule(Schedule schedule, Map<String,Serializable> parameters) Registers a schedule.
protected void	schedule(Schedule schedule, Map<String,Serializable> parameters)
protected void	setupScheduler()
protected void	shutdownScheduler()
void	unregisterExtension(Extension extension) Unregisters the given extension.
boolean	unregisterSchedule(Schedule schedule) UnRegisters a schedule.
boolean	unregisterSchedule(String id) UnRegisters a schedule.
protected boolean	unschedule(String jobId)

Methods inherited from class org.nuxeo.runtime.model.DefaultComponent

getAdapter, getApplicationStartedOrder, getLastModified, registerContribution, setLastModified, setModifiedNow, unregisterContribution

Methods inherited from class java.lang.Object

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

Field Detail

context

protected RuntimeContext context

scheduler

protected org.quartz.Scheduler scheduler

registry

protected final ScheduleExtensionRegistry registry

Constructor Detail

SchedulerServiceImpl

public SchedulerServiceImpl()

Method Detail

activate

public void activate(ComponentContext context)

Description copied from interface: Component

Activates the component.

This method is called by the runtime when a component is activated.

Specified by:

activate in interface Component

Overrides:

activate in class DefaultComponent

Parameters:

context - the runtime context

setupScheduler

protected void setupScheduler()
                       throws IOException,
                              org.quartz.SchedulerException

Throws:

IOException

org.quartz.SchedulerException

shutdownScheduler

protected void shutdownScheduler()

deactivate

public void deactivate(ComponentContext context)

Description copied from interface: Component

Deactivates the component.

This method is called by the runtime when a component is deactivated.

Specified by:

deactivate in interface Component

Overrides:

deactivate in class DefaultComponent

Parameters:

context - the runtime context

applicationStarted

public void applicationStarted(ComponentContext context)

Description copied from interface: Component

Notify the component that Nuxeo Framework finished starting all Nuxeo bundles.

Specified by:

applicationStarted in interface Component

Overrides:

applicationStarted in class DefaultComponent

hasApplicationStarted

public boolean hasApplicationStarted()

Description copied from interface: SchedulerService

Checks if the framework has fully started.

Used to delay job execution until the framework has fully started.

Specified by:

hasApplicationStarted in interface SchedulerService

Returns:

true if the framework has started

registerExtension

public void registerExtension(Extension extension)

Description copied from interface: Extensible

Registers the given extension.

Specified by:

registerExtension in interface Extensible

Overrides:

registerExtension in class DefaultComponent

Parameters:

extension - the extension to register

unregisterExtension

public void unregisterExtension(Extension extension)

Description copied from interface: Extensible

Unregisters the given extension.

Specified by:

unregisterExtension in interface Extensible

Overrides:

unregisterExtension in class DefaultComponent

Parameters:

extension - the extension to unregister

getContext

public RuntimeContext getContext()

registerSchedule

public void registerSchedule(Schedule schedule)

Description copied from interface: SchedulerService

Registers a schedule.

Specified by:

registerSchedule in interface SchedulerService

Parameters:

schedule - the schedule

registerSchedule

public void registerSchedule(Schedule schedule,
                             Map<String,Serializable> parameters)

Description copied from interface: SchedulerService

Registers a schedule. Add all parameters to eventContext.

Specified by:

registerSchedule in interface SchedulerService

schedule

protected void schedule(Schedule schedule,
                        Map<String,Serializable> parameters)

unregisterSchedule

public boolean unregisterSchedule(String id)

Description copied from interface: SchedulerService

UnRegisters a schedule.

Specified by:

unregisterSchedule in interface SchedulerService

Parameters:

id - the schedule id

Returns:

true if schedule has been successfully removed.

unschedule

protected boolean unschedule(String jobId)

unregisterSchedule

public boolean unregisterSchedule(Schedule schedule)

Description copied from interface: SchedulerService

UnRegisters a schedule.

Specified by:

unregisterSchedule in interface SchedulerService

Parameters:

schedule - to be unregistered

Returns:

true if schedule has been successfully removed.

handleEvent

public void handleEvent(RuntimeServiceEvent event)

Specified by:

handleEvent in interface RuntimeServiceListener