WebSphere:*,type=SchedulerSR
MBean SchedulerSR
CR interface for LongRunning Scheduler functions in specific SR
Operation Summary | |
---|---|
java.lang.String | requeueSubmissions() Returns a unique jobID |
java.lang.Integer | dispatch( Dispatches a job |
java.lang.String | getJobID( Returns a unique jobID |
com.ibm.ws.batch.JobStatusDO | updateJobStatus() Updates a job's status in the LRS |
com.ibm.ws.batch.JobStatusDO | setJobState( Sets job's status in the LRS |
void | processPGCJobStatus( Process a job status message coming from proxy servlet |
void | processJobStatusMessage( Process a job status message coming from Global Job Ststus Listener |
void | markFailedServerJobs( Sets job's status in the LRS to restartable state |
void | jobStatusResubscribe( Initiates endpoint job status listener in the LRS for the job which was executing |
com.ibm.ws.batch.JobStatusDO[] | getAllJobsByStatus( get all jobs by status |
java.lang.String | getxJCLSource( get xJCL source based on jobid |
void | recreateRecurringRequestAlarms() recreate alarms for Recurring Requests in the system after a scheduler restart |
java.lang.String | submitRecurringJobFromRepository( submit a recurring job based on a job in the job repository |
void | scheduleJob( schedule a job given a jobid |
com.ibm.ws.batch.RecurringRequestDO[] | getAllRecurringRequests() get all recurring requests |
com.ibm.ws.longrun.Job | setEpsCounters( Sets EPS counter values for a job |
void | setSystemStreams( Sets System. |
java.lang.Boolean | createJobProfile( Create a new job profile if one does not exists |
com.ibm.ws.batch.JobProfileDO | retrieveJobProfile( Retrieve job profile for job class |
java.lang.Boolean | deleteJobProfile( Delete a job profile |
void | updateJobProfile( Update an existing job profile |
java.lang.Boolean | incrementOutStandingJobs( Increment number of outstanding jobs for a class |
void | decrementOutStandingJobs( Decrement number of outstanding jobs for a class |
void | addJobToJobClassExeRecTable( Add job to class |
void | removeJobFromJobClassExeRecTable( Remove job from class |
void | enforceJobOutputQueueLimits( Enforce queue limits |
void | updateJobUsage( Update job usage |
java.lang.String | getJobUsageBySubmitter( Get job usage by submitter |
java.lang.String | getJobUsageByJob( Get job usage by job |
java.lang.String | getAllJobUsage() Get all job usage |
void | jobLog( log a job message |
void | jobLog( log a job message |
java.lang.Boolean | logUsingProbe( log a job message using classname and probe |
void | log( log a job message |
java.lang.String | chkSection( Returns job log section |
java.util.ArrayList | queryJobsByClass( Query jobs by job class |
void | cleanupClassList( Remove job from class table |
void | cleanupLogList( Remove job from log table |
java.lang.String | getOwningScheduler( get the job owning scheduler |
void | updateOwningScheduler( update the job owning scheduler |
java.lang.Integer | updateOwningScheduler( update the job owning scheduler |
void | updateRRsOwningScheduler( update a schedule's owning scheduler |
com.ibm.ws.batch.JobUsageDO[] | getJobUsageByJobIdOfAllStartTime( Get job usage by job id |
void | processStepStatusMessage( process a job's step status message |
java.util.List | getOwnedJobsInNonFinalState( Get list of jobs in non final state in the endpoint |
void | sendStepStatusJMXNotification( Send step status JMX notification |
Operation Detail |
---|
public java.lang.String requeueSubmissions()
public java.lang.Integer dispatch(com.ibm.ws.longrun.Job job,
java.util.List permittedEndpoints
)
job
-
Job to dispatchpermittedEndpoints
-
List of permitted endpoints ordered by best equalization linepublic java.lang.String getJobID(java.lang.String jobName,
java.lang.Integer jobNumber
)
jobName
-
Job namejobNumber
-
Job sequence numberpublic com.ibm.ws.batch.JobStatusDO updateJobStatus()
public com.ibm.ws.batch.JobStatusDO setJobState(java.lang.String jobID,
java.lang.String newState
)
jobID
-
the job idnewState
-
the statepublic void processPGCJobStatus(com.ibm.ws.gridcontainer.communication.StatusUpdateMessage update
)
update
-
the status objectpublic void processJobStatusMessage(java.lang.String msg
)
msg
-
the status messagepublic void markFailedServerJobs(java.lang.String endpoint
)
endpoint
-
The failing endpoint namepublic void jobStatusResubscribe(java.lang.String endpoint
)
endpoint
-
The endpoint name which was executing the job when the scheduler failedpublic com.ibm.ws.batch.JobStatusDO[] getAllJobsByStatus(java.lang.Integer status
)
status
-
job statuspublic java.lang.String getxJCLSource(java.lang.String jobID
)
jobID
-
the job idpublic void recreateRecurringRequestAlarms()
public java.lang.String submitRecurringJobFromRepository(java.lang.String jobName,
java.lang.String startTime,
java.lang.String nameValuePairs,
java.lang.String submitter
)
jobName
-
the job namestartTime
-
time to start jobnameValuePairs
-
symbolic variable name value pairssubmitter
-
submitterpublic void scheduleJob(java.lang.String jobid,
java.lang.String submitter
)
jobid
-
the job idsubmitter
-
the job submitter idpublic com.ibm.ws.batch.RecurringRequestDO[] getAllRecurringRequests()
public com.ibm.ws.longrun.Job setEpsCounters(com.ibm.ws.longrun.Job job
)
job
-
Job for counterspublic void setSystemStreams(java.lang.String schedulerName
)
schedulerName
-
The Job Scheduler namepublic java.lang.Boolean createJobProfile(java.lang.String jobClass
)
jobClass
-
Name of job classpublic com.ibm.ws.batch.JobProfileDO retrieveJobProfile(java.lang.String jobClass
)
jobClass
-
Name of job classpublic java.lang.Boolean deleteJobProfile(java.lang.String jobClass
)
jobClass
-
Name of job classpublic void updateJobProfile(com.ibm.ws.batch.JobProfileDO profile,
java.lang.Long lastUpdate
)
profile
-
updated profilelastUpdate
-
last update timepublic java.lang.Boolean incrementOutStandingJobs(java.lang.String jobClass,
java.lang.Integer maxCount
)
jobClass
-
Job ClassmaxCount
-
max countpublic void decrementOutStandingJobs(java.lang.String jobClass
)
jobClass
-
Job Classpublic void addJobToJobClassExeRecTable(java.lang.String jobID,
java.lang.String jobClass,
java.lang.Long time
)
jobID
-
Job IDjobClass
-
Job Classtime
-
timepublic void removeJobFromJobClassExeRecTable(java.lang.String[] jobID
)
jobID
-
Array of Job IDspublic void enforceJobOutputQueueLimits(java.lang.String jobClassName,
java.lang.Integer maxCount,
java.lang.Integer maxAge
)
jobClassName
-
Job Class namemaxCount
-
max countmaxAge
-
max agepublic void updateJobUsage(com.ibm.ws.batch.sensor.EndpointSensorJob[] jobs
)
jobs
-
update job usagepublic java.lang.String getJobUsageBySubmitter(java.lang.String submitter
)
submitter
-
name of submitterpublic java.lang.String getJobUsageByJob(java.lang.String jobid,
java.lang.Long startTime
)
jobid
-
job idstartTime
-
job start timepublic java.lang.String getAllJobUsage()
public void jobLog(java.lang.String jobID,
java.lang.String message,
java.lang.String message
)
jobID
-
job identifiermessage
-
message textmessage
-
scheduler namepublic void jobLog(java.lang.String jobID,
java.lang.String message
)
jobID
-
job identifiermessage
-
message textpublic java.lang.Boolean logUsingProbe(java.lang.String jobID,
java.lang.String probe,
java.lang.String className,
java.lang.Object[] details
)
jobID
-
job identifierprobe
-
probe identifierclassName
-
caller class namedetails
-
array of message substitution detailspublic void log(java.lang.String jobID,
java.lang.String message
)
jobID
-
job identifiermessage
-
message textpublic java.lang.String chkSection(java.lang.String jobSubDir
)
jobSubDir
-
Job log subdirectorypublic java.util.ArrayList queryJobsByClass(java.lang.String jobClass,
java.lang.String jobToSearchFor
)
jobClass
-
Job ClassjobToSearchFor
-
Job IDpublic void cleanupClassList(java.lang.String partInfo
)
partInfo
-
Job IDpublic void cleanupLogList(java.lang.String jobID
)
jobID
-
Job IDpublic java.lang.String getOwningScheduler(java.lang.String jobID
)
jobID
-
job identifierpublic void updateOwningScheduler(java.lang.String jobID,
java.lang.String newSchedulerName
)
jobID
-
job identifiernewSchedulerName
-
new job scheduler namepublic java.lang.Integer updateOwningScheduler(java.lang.String jobID,
java.lang.String newSchedulerName,
java.lang.String oldSchedulerName
)
jobID
-
job identifiernewSchedulerName
-
new job scheduler nameoldSchedulerName
-
old job scheduler namepublic void updateRRsOwningScheduler(com.ibm.ws.batch.RecurringRequestDO rrDO,
java.lang.String oldSchedulerName
)
rrDO
-
schedule informationoldSchedulerName
-
old job scheduler namepublic com.ibm.ws.batch.JobUsageDO[] getJobUsageByJobIdOfAllStartTime(java.lang.String jobid
)
jobid
-
job idpublic void processStepStatusMessage(java.lang.String msgTxt
)
msgTxt
-
the status messagepublic java.util.List getOwnedJobsInNonFinalState(java.lang.String endpointName
)
endpointName
-
EP namepublic void sendStepStatusJMXNotification(java.lang.String notificationType,
java.lang.String jobId,
java.lang.String stepName,
java.lang.String startTime,
java.lang.String endTime,
java.lang.Integer statusCode,
java.lang.Integer rc
)
notificationType
-
type of notificationjobId
-
job id of this stepstepName
-
job step namestartTime
-
time job step startsendTime
-
time job step endsstatusCode
-
job step status coderc
-
job step return code