net.bluemind.scheduledjob.scheduler.impl

Class Scheduler

java.lang.Object

net.bluemind.scheduledjob.scheduler.impl.Scheduler

All Implemented Interfaces:

IRecordingListener, IScheduler

public class Scheduler
extends java.lang.Object
implements IScheduler, IRecordingListener

Method Summary

Modifier and Type	Method and Description
java.util.Set<java.lang.String>	checkLockedResources(java.lang.String domain, IScheduledJob bj)
void	error(IScheduledJobRunId rid, java.lang.String locale, java.lang.String logEntry)
void	finish(IScheduledJobRunId irid, JobExitStatus status) Called by jobs at the end of the tick method when no exception occured.
static Scheduler	get()
IScheduledJobRunId	getActiveSlot(java.lang.String domainName, java.lang.String jid)
java.util.Map<java.lang.String,RunIdImpl>	getActiveSlots() Returns a copy of the running jobs list
void	info(IScheduledJobRunId rid, java.lang.String locale, java.lang.String logEntry)
void	recordingComplete(RunIdImpl rid)
void	reportProgress(IScheduledJobRunId rid, int percent)
IScheduledJobRunId	requestSlot(java.lang.String domainName, IScheduledJob bj, java.util.Date startDate) Request an execution id to start a job.
void	setActiveGroup(java.lang.String execGroup)
void	tryRun(JobTicker runner)
void	warn(IScheduledJobRunId rid, java.lang.String locale, java.lang.String logEntry)

Methods inherited from class java.lang.Object

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

Method Detail

requestSlot

public IScheduledJobRunId requestSlot(java.lang.String domainName,
                                      IScheduledJob bj,
                                      java.util.Date startDate)
                               throws ServerFault

Description copied from interface: IScheduler

Request an execution id to start a job. The task must not do anything if this method returns null or throws an exception. The exception received here MUST be re-thrown to parent.

Specified by:

requestSlot in interface IScheduler

Returns:

Throws:

ServerFault

info

public void info(IScheduledJobRunId rid,
                 java.lang.String locale,
                 java.lang.String logEntry)

Specified by:

info in interface IScheduler

warn

public void warn(IScheduledJobRunId rid,
                 java.lang.String locale,
                 java.lang.String logEntry)

Specified by:

warn in interface IScheduler

error

public void error(IScheduledJobRunId rid,
                  java.lang.String locale,
                  java.lang.String logEntry)

Specified by:

error in interface IScheduler

reportProgress

public void reportProgress(IScheduledJobRunId rid,
                           int percent)

Specified by:

reportProgress in interface IScheduler

finish

public void finish(IScheduledJobRunId irid,
                   JobExitStatus status)

Description copied from interface: IScheduler

Called by jobs at the end of the tick method when no exception occured.

Specified by:

finish in interface IScheduler

recordingComplete

public void recordingComplete(RunIdImpl rid)

Specified by:

recordingComplete in interface IRecordingListener

get

public static Scheduler get()

getActiveSlot

public IScheduledJobRunId getActiveSlot(java.lang.String domainName,
                                        java.lang.String jid)

tryRun

public void tryRun(JobTicker runner)

setActiveGroup

public void setActiveGroup(java.lang.String execGroup)

getActiveSlots

public java.util.Map<java.lang.String,RunIdImpl> getActiveSlots()

Returns a copy of the running jobs list

Returns:

checkLockedResources

public java.util.Set<java.lang.String> checkLockedResources(java.lang.String domain,
                                                            IScheduledJob bj)