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 | 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 | 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 |
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 line
public java.lang.String getJobID(java.lang.String jobName,
java.lang.Integer jobNumber
)
jobName
-
Job namejobNumber
-
Job sequence number
public 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 state
public void processJobStatusMessage(java.lang.String msg
)
msg
-
the status message
public void markFailedServerJobs(java.lang.String endpoint
)
endpoint
-
The failing endpoint name
public void jobStatusResubscribe(java.lang.String endpoint
)
endpoint
-
The endpoint name which was executing the job when the scheduler failed
public com.ibm.ws.batch.JobStatusDO[] getAllJobsByStatus(java.lang.Integer status
)
status
-
job status
public java.lang.String getxJCLSource(java.lang.String jobID
)
jobID
-
the job id
public 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
-
submitter
public void scheduleJob(java.lang.String jobid,
java.lang.String submitter
)
jobid
-
the job idsubmitter
-
the job submitter id
public com.ibm.ws.batch.RecurringRequestDO[] getAllRecurringRequests()
public com.ibm.ws.longrun.Job setEpsCounters(com.ibm.ws.longrun.Job job
)
job
-
Job for counters
public void setSystemStreams(java.lang.String schedulerName
)
schedulerName
-
The Job Scheduler name
public java.lang.Boolean createJobProfile(java.lang.String jobClass
)
jobClass
-
Name of job class
public com.ibm.ws.batch.JobProfileDO retrieveJobProfile(java.lang.String jobClass
)
jobClass
-
Name of job class
public java.lang.Boolean deleteJobProfile(java.lang.String jobClass
)
jobClass
-
Name of job class
public void updateJobProfile(com.ibm.ws.batch.JobProfileDO profile,
java.lang.Long lastUpdate
)
profile
-
updated profilelastUpdate
-
last update time
public java.lang.Boolean incrementOutStandingJobs(java.lang.String jobClass,
java.lang.Integer maxCount
)
jobClass
-
Job ClassmaxCount
-
max count
public void decrementOutStandingJobs(java.lang.String jobClass
)
jobClass
-
Job Class
public void addJobToJobClassExeRecTable(java.lang.String jobID,
java.lang.String jobClass,
java.lang.Long time
)
jobID
-
Job IDjobClass
-
Job Classtime
-
time
public void removeJobFromJobClassExeRecTable(java.lang.String[] jobID
)
jobID
-
Array of Job IDs
public void enforceJobOutputQueueLimits(java.lang.String jobClassName,
java.lang.Integer maxCount,
java.lang.Integer maxAge
)
jobClassName
-
Job Class namemaxCount
-
max countmaxAge
-
max age
public void updateJobUsage(com.ibm.ws.batch.sensor.EndpointSensorJob[] jobs
)
jobs
-
update job usage
public java.lang.String getJobUsageBySubmitter(java.lang.String submitter
)
submitter
-
name of submitter
public java.lang.String getJobUsageByJob(java.lang.String jobid,
java.lang.Long startTime
)
jobid
-
job idstartTime
-
job start time
public 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 name
public void jobLog(java.lang.String jobID,
java.lang.String message
)
jobID
-
job identifiermessage
-
message text
public 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 details
public void log(java.lang.String jobID,
java.lang.String message
)
jobID
-
job identifiermessage
-
message text
public java.lang.String getOwningScheduler(java.lang.String jobID
)
jobID
-
job identifier
public void updateOwningScheduler(java.lang.String jobID,
java.lang.String newSchedulerName
)
jobID
-
job identifiernewSchedulerName
-
new job scheduler name
public 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 name
public void updateRRsOwningScheduler(com.ibm.ws.batch.RecurringRequestDO rrDO,
java.lang.String oldSchedulerName
)
rrDO
-
schedule informationoldSchedulerName
-
old job scheduler name
public com.ibm.ws.batch.JobUsageDO[] getJobUsageByJobIdOfAllStartTime(java.lang.String jobid
)
jobid
-
job id
public void processStepStatusMessage(java.lang.String msgTxt
)
msgTxt
-
the status message
public java.util.List getOwnedJobsInNonFinalState(java.lang.String endpointName
)
endpointName
-
EP name