| java.lang.Object org.ofbiz.service.job.JobManager
JobManager | public class JobManager (Code) | | JobManager
|
Method Summary | |
public void | finalize() | public GenericDelegator | getDelegator() Returns the GenericDelegator. | public LocalDispatcher | getDispatcher() Returns the ServiceDispatcher. | public static RecurrenceInfo | getRecurrenceInfo(GenericValue job) gets the recurrence info object for a job. | public void | killThread(String threadName) Kill a JobInvoker Thread. | public synchronized Iterator | poll() | public List | processList() Get a List of each threads current state. | public synchronized void | reloadCrashedJobs() | public void | runJob(Job job) Queues a Job to run now. | public void | schedule(String serviceName, Map context, long startTime, int frequency, int interval, int count) | public void | schedule(String serviceName, Map context, long startTime, int frequency, int interval, long endTime) | public void | schedule(String serviceName, Map context, long startTime, int frequency, int interval, int count, long endTime) | public void | schedule(String poolName, String serviceName, Map context, long startTime, int frequency, int interval, int count, long endTime) | public void | schedule(String jobName, String poolName, String serviceName, Map context, long startTime, int frequency, int interval, int count, long endTime, int maxRetry) | public void | schedule(String poolName, String serviceName, String dataId, long startTime) | public void | schedule(String jobName, String poolName, String serviceName, String dataId, long startTime, int frequency, int interval, int count, long endTime, int maxRetry) | public void | shutdown() Close out the scheduler thread. |
dispatcherName | final public static String dispatcherName(Code) | | |
registeredManagers | public static Map registeredManagers(Code) | | |
updateFields | final public static Map updateFields(Code) | | |
killThread | public void killThread(String threadName)(Code) | | Kill a JobInvoker Thread.
Parameters: threadName - Name of the JobInvoker Thread to kill. |
processList | public List processList()(Code) | | Get a List of each threads current state.
List containing a Map of each thread's state. |
reloadCrashedJobs | public synchronized void reloadCrashedJobs()(Code) | | |
schedule | public void schedule(String serviceName, Map context, long startTime, int frequency, int interval, int count) throws JobManagerException(Code) | | Schedule a job to start at a specific time with specific recurrence info
Parameters: serviceName - The name of the service to invoke Parameters: context - The context for the service Parameters: startTime - The time in milliseconds the service should run Parameters: frequency - The frequency of the recurrence (HOURLY,DAILY,MONTHLY,etc) Parameters: interval - The interval of the frequency recurrence Parameters: count - The number of times to repeat |
schedule | public void schedule(String serviceName, Map context, long startTime, int frequency, int interval, long endTime) throws JobManagerException(Code) | | Schedule a job to start at a specific time with specific recurrence info
Parameters: serviceName - The name of the service to invoke Parameters: context - The context for the service Parameters: startTime - The time in milliseconds the service should run Parameters: frequency - The frequency of the recurrence (HOURLY,DAILY,MONTHLY,etc) Parameters: interval - The interval of the frequency recurrence Parameters: endTime - The time in milliseconds the service should expire |
schedule | public void schedule(String serviceName, Map context, long startTime, int frequency, int interval, int count, long endTime) throws JobManagerException(Code) | | Schedule a job to start at a specific time with specific recurrence info
Parameters: serviceName - The name of the service to invoke Parameters: context - The context for the service Parameters: startTime - The time in milliseconds the service should run Parameters: frequency - The frequency of the recurrence (HOURLY,DAILY,MONTHLY,etc) Parameters: interval - The interval of the frequency recurrence Parameters: count - The number of times to repeat Parameters: endTime - The time in milliseconds the service should expire |
schedule | public void schedule(String poolName, String serviceName, Map context, long startTime, int frequency, int interval, int count, long endTime) throws JobManagerException(Code) | | Schedule a job to start at a specific time with specific recurrence info
Parameters: poolName - The name of the pool to run the service from Parameters: serviceName - The name of the service to invoke Parameters: context - The context for the service Parameters: startTime - The time in milliseconds the service should run Parameters: frequency - The frequency of the recurrence (HOURLY,DAILY,MONTHLY,etc) Parameters: interval - The interval of the frequency recurrence Parameters: count - The number of times to repeat Parameters: endTime - The time in milliseconds the service should expire |
schedule | public void schedule(String jobName, String poolName, String serviceName, Map context, long startTime, int frequency, int interval, int count, long endTime, int maxRetry) throws JobManagerException(Code) | | Schedule a job to start at a specific time with specific recurrence info
Parameters: jobName - The name of the job Parameters: poolName - The name of the pool to run the service from Parameters: serviceName - The name of the service to invoke Parameters: context - The context for the service Parameters: startTime - The time in milliseconds the service should run Parameters: frequency - The frequency of the recurrence (HOURLY,DAILY,MONTHLY,etc) Parameters: interval - The interval of the frequency recurrence Parameters: count - The number of times to repeat Parameters: endTime - The time in milliseconds the service should expire Parameters: maxRetry - The max number of retries on failure (-1 for no max) |
schedule | public void schedule(String poolName, String serviceName, String dataId, long startTime) throws JobManagerException(Code) | | Schedule a job to start at a specific time with specific recurrence info
Parameters: poolName - The name of the pool to run the service from Parameters: serviceName - The name of the service to invoke Parameters: dataId - The persisted context (RuntimeData.runtimeDataId) Parameters: startTime - The time in milliseconds the service should run |
schedule | public void schedule(String jobName, String poolName, String serviceName, String dataId, long startTime, int frequency, int interval, int count, long endTime, int maxRetry) throws JobManagerException(Code) | | Schedule a job to start at a specific time with specific recurrence info
Parameters: jobName - The name of the job Parameters: poolName - The name of the pool to run the service from Parameters: serviceName - The name of the service to invoke Parameters: dataId - The persisted context (RuntimeData.runtimeDataId) Parameters: startTime - The time in milliseconds the service should run Parameters: frequency - The frequency of the recurrence (HOURLY,DAILY,MONTHLY,etc) Parameters: interval - The interval of the frequency recurrence Parameters: count - The number of times to repeat Parameters: endTime - The time in milliseconds the service should expire Parameters: maxRetry - The max number of retries on failure (-1 for no max) |
shutdown | public void shutdown()(Code) | | Close out the scheduler thread.
|
|
|