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 | markFailedPGCServerJobs( Sets job's status from PGC endpoint 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 |
void | queued( PMI stat queued |
void | dispatched( PMI stat dispatched |
void | dispatchError( PMI stat dispatch error |
void | dispatchFailed( PMI stat dispatch failed |
void | jobCompleted( PMI stat job completed |
void | removedFromQueue( PMI stat job removed from queue |
void | executeRedoList( Execute jobs that are currently in the redo list for this endpoint |
java.lang.Long | getLastRunTimeFromDB( get lastRunTime value from DB |
void | startThreadToRunCapacityLeakDetection( Start thread to run job class capacity leak detection |
void | saveJobLogSectionFromCR( save job log section, caller is from CR |
java.lang.String | getOwningSchedulerFromRRStore( get owning scheduler from recurring request store |
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 markFailedPGCServerJobs(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 codepublic void queued(java.lang.String txc,
java.lang.String app,
java.lang.String module
)
txc
-
transaction classapp
-
application namemodule
-
module namepublic void dispatched(java.lang.String txc,
java.lang.String app,
java.lang.String module,
java.lang.Long timeInQueue,
java.lang.Long timeToDispatch
)
txc
-
transaction classapp
-
application namemodule
-
module nametimeInQueue
-
time in queuetimeToDispatch
-
time to dispatchpublic void dispatchError(java.lang.String txc,
java.lang.String app,
java.lang.String module,
java.lang.Long errTime
)
txc
-
transaction classapp
-
application namemodule
-
module nameerrTime
-
dispatch error timepublic void dispatchFailed(java.lang.String txc,
java.lang.String app,
java.lang.String module,
java.lang.Long timeInQueue
)
txc
-
transaction classapp
-
application namemodule
-
module nametimeInQueue
-
time in queuepublic void jobCompleted(java.lang.String txc,
java.lang.String app,
java.lang.String module
)
txc
-
transaction classapp
-
application namemodule
-
module namepublic void removedFromQueue(java.lang.String txc,
java.lang.String app,
java.lang.String module
)
txc
-
transaction classapp
-
application namemodule
-
module namepublic void executeRedoList(java.lang.String endpointName
)
endpointName
-
EP namepublic java.lang.Long getLastRunTimeFromDB(java.lang.String jobClass
)
jobClass
-
Job Classpublic void startThreadToRunCapacityLeakDetection(java.lang.Boolean recoverCapacity,
java.lang.Boolean isFirstRun
)
recoverCapacity
-
determine if recover action should be performedisFirstRun
-
indicate if this is the first runpublic void saveJobLogSectionFromCR(java.lang.String logSubDir,
java.lang.String server,
java.lang.String node,
java.lang.String logDir
)
logSubDir
-
log sub dirserver
-
server namenode
-
nodelogDir
-
log dirpublic java.lang.String getOwningSchedulerFromRRStore(java.lang.String requestId
)
requestId
-
requestId