WebSphere:*,type=SchedulerCR
MBean SchedulerCR
z/OS SR-CR hopper for LongRunning Scheduler
Operation Summary | |
---|---|
java.lang.String | init() Initializes LRS Component |
void | uninit() Uninitializes LRS Component |
void | deregister() Deregisters MBean |
void | createJobStatus( Publishes a job's status to the Bulletin Board |
void | EPSComplete( Notifies the EPS of a job's ending status |
void | EPSRemove( Removes a job from the EPS |
java.lang.String | getJobID( Gets a job id assigned to a new job |
void | incrementJobLogCount( Increments the job log counter |
void | decrementJobLogCount( Decrements the job log counter |
java.lang.String | getSubDirectory() Gets the job log subdirectory |
java.lang.Boolean | schedule( Gets a job id assigned to a new job |
java.lang.Boolean | queue( Queues job to GAPAgent |
void | invokeEndpoint( Invokes the Endpoint Web Service |
java.lang.String | findBestNodeToDisable( Finds the best Node to Disable in a NodeGroup |
java.lang.String | findBestLocation( Finds the best Node |
void | createDJQ() Creates a Delayed Job Queuer in the CR |
void | createDJQAlarm() Creates an AlarmManager alarm in the CR for the Delayed Job Queuer |
void | djqAdd( adds an element to the Delayed Job Queuer in the CR |
void | djqRemove( Remove an element from the Delayed Job Queuer in the CR |
java.lang.Integer | djqSize() returns the size of the Delayed Job Queue |
void | createRecurringRequestAlarm( Creates an AlarmManager alarm in the CR for Recurring Request |
com.ibm.ws.batch.RecurringRequestAlarmListener | createRecurringRequestListener( Creates an alarm listener for Recurring Request Alarm in the CR |
void | cancelRecurringRequestAlarm( Cancels a Recurring Request Alarm alarm in the CR |
void | recreateRecurringRequestAlarms( Creates an alarm in the CR to reinit existing Recurring Requests |
void | createJobStatusSubject( createJobStatusSubject |
void | dsjQueueAdd( dsjQueueAdd |
void | dsjQueueRemove( dsjQueueRemove |
void | displayDSJQueueContents() displayDSJQueueContents |
void | createRecurringRequest( createRecurringRequest |
void | removeJobStatusSubscription( Invoke Global Job Status listener to remove a job status Subscription |
void | cleanupJobClassInfo( Clean up job calss info. |
void | invokeGridEndpoint( Perform operation on Grid Utility job. |
java.lang.Boolean | isApplicationInstalled( Verify if the application is installed |
java.lang.Boolean | isSchedulerActive( Verify if the a scheduler is active |
com.ibm.ws.longrun.EndPoint | getGAPEndpoint( Retrieve an EndPoint object from GAPNodesTable. |
void | setJobEndpoint( Set the selected Endpoint for a job. |
void | writeSMF( writeSMF |
void | removeXJCLJobFromCache( removeXJCLJobFromCache |
java.lang.String[] | getJobLogPartListFromPGCEndpoint( Get the job log parts for the given job |
java.lang.String | getJobLogPartFromPGCEndpoint( Get the String corresponding to the job log part |
void | updateOwningSchedulerOnPGCEndpoint( Inform the Endpoint of the new owner of the given list of jobs |
void | invokePortableGridEndpoint( Invoke the given command on the given PGC endpoint |
void | processMessagesFromPGCEndpoint( Process job status messages from PGC endpoint |
void | processPGCEndpointStatusUpdate( Process heart beat message from PGC endpoint |
com.ibm.ws.longrun.EndPoint | processJobWithoutDispatch( Process job without dispatch |
java.lang.String | IOAPAR_getJobLogPartFromPGCEndpoint( Get the String corresponding to the job log part |
void | notifyGAPAboutJobClassCapacityUpdate( notify Gap |
void | resetDetectionRunFlag( reset flag |
Operation Detail |
---|
public java.lang.String init()
public void uninit()
public void deregister()
public void createJobStatus(java.lang.String jobid
)
jobid
-
Job IDpublic void EPSComplete(java.lang.String jobid,
java.lang.String node,
java.lang.String appServer,
java.lang.String jobType
)
jobid
-
Job IDnode
-
node nameappServer
-
server namejobType
-
job typepublic void EPSRemove(java.lang.String jobid
)
jobid
-
Job IDpublic java.lang.String getJobID(java.lang.String jobName
)
jobName
-
Job namepublic void incrementJobLogCount(java.lang.String extendedSection
)
extendedSection
-
Sectionpublic void decrementJobLogCount(java.lang.String extendedSection
)
extendedSection
-
Sectionpublic java.lang.String getSubDirectory()
public java.lang.Boolean schedule(java.lang.String xJCL,
java.lang.String jobid,
java.lang.String submitter
)
xJCL
-
xJCLjobid
-
Job IDsubmitter
-
Job Submitter IDpublic java.lang.Boolean queue(com.ibm.ws.longrun.Job job
)
job
-
Job to be dispatchedpublic void invokeEndpoint(java.lang.String node,
java.lang.String server,
java.lang.String opName,
java.lang.Object[] parms,
java.lang.String[] signature,
java.lang.String epArgs
)
node
-
node of targetserver
-
target serveropName
-
operationparms
-
parmssignature
-
signature of parmsepArgs
-
arguments for EPSpublic java.lang.String findBestNodeToDisable(java.lang.String nodeGroupName
)
nodeGroupName
-
the Node Grouppublic java.lang.String findBestLocation(java.lang.String dcMemberName,
java.lang.String oldNodeGroupName,
java.lang.Integer healthCondition
)
dcMemberName
-
the DC NameoldNodeGroupName
-
the Node Group NamehealthCondition
-
the health indicatorpublic void createDJQ()
public void createDJQAlarm()
public void djqAdd(com.ibm.ws.longrun.Job job
)
job
-
the Job to addpublic void djqRemove(java.lang.String jobID
)
jobID
-
The Job ID to Removepublic java.lang.Integer djqSize()
public void createRecurringRequestAlarm(java.lang.String reqId,
java.lang.Long nextStartTime,
com.ibm.ws.batch.RecurringRequestAlarmListener rrAL
)
reqId
-
name of requestnextStartTime
-
alarm activation timerrAL
-
listener for this alarmpublic com.ibm.ws.batch.RecurringRequestAlarmListener createRecurringRequestListener(com.ibm.ws.batch.RecurringRequestDO rrDO
)
rrDO
-
Recurring Request Data Objectpublic void cancelRecurringRequestAlarm(java.lang.String reqId
)
reqId
-
name of requestpublic void recreateRecurringRequestAlarms(com.ibm.ws.batch.RecurringRequestDO[] rrDO
)
rrDO
-
recurring request data objectspublic void createJobStatusSubject(com.ibm.ws.batch.JobStatusDO[] jsDO
)
jsDO
-
array of job status data objectpublic void dsjQueueAdd(com.ibm.ws.batch.DelayedSubmitJob dsj
)
dsj
-
name of delayed submit job to addpublic void dsjQueueRemove(com.ibm.ws.batch.DelayedSubmitJob dsj
)
dsj
-
name of delayed submit job to removepublic void displayDSJQueueContents()
public void createRecurringRequest(com.ibm.ws.batch.RecurringRequestDO rrDO,
java.lang.Long durationToStart
)
rrDO
-
recurring request data objectdurationToStart
-
duration to start recurring jobspublic void removeJobStatusSubscription(java.lang.String jobID
)
jobID
-
jobidpublic void cleanupJobClassInfo(java.util.ArrayList jobsToRemoveList
)
jobsToRemoveList
-
List of jobs.public void invokeGridEndpoint(java.lang.String opName,
java.lang.String jobID
)
opName
-
Operation Type.jobID
-
Job ID.public java.lang.Boolean isApplicationInstalled(java.lang.String applicationName
)
applicationName
-
Name of the applicationpublic java.lang.Boolean isSchedulerActive(java.lang.String schedulerNameInBBformat
)
schedulerNameInBBformat
-
Scheduler Name In BB formatpublic com.ibm.ws.longrun.EndPoint getGAPEndpoint(java.lang.String endpointName
)
endpointName
-
Name of the endpoint (nodeName/serverName)public void setJobEndpoint(java.lang.String jobid,
com.ibm.ws.longrun.EndPoint endpoint
)
jobid
-
Job IDendpoint
-
Selected endpointpublic void writeSMF(com.ibm.ws.batch.JobUsageDO[] juDO,
java.lang.Integer recordCount
)
juDO
-
array of job usage data objectrecordCount
-
count of job usage data objects for ended jobspublic void removeXJCLJobFromCache(java.lang.String jobId
)
jobId
-
job id to remove from cachepublic java.lang.String[] getJobLogPartListFromPGCEndpoint(java.lang.String jobId,
com.ibm.ws.longrun.EndPoint endpoint
)
jobId
-
Job id whoose parts are requestedendpoint
-
Endpoint where job is runningpublic java.lang.String getJobLogPartFromPGCEndpoint(java.lang.String jobId,
java.lang.String partNo,
com.ibm.ws.longrun.EndPoint endpoint
)
jobId
-
Job id whoose part is requestedpartNo
-
Job log part requestedendpoint
-
Endpoint where job is runningpublic void updateOwningSchedulerOnPGCEndpoint(java.util.Map endpointToJobMap,
java.lang.String schedulerName
)
endpointToJobMap
-
endpoint to Job mapschedulerName
-
The new owning schedulerpublic void invokePortableGridEndpoint(com.ibm.ws.longrun.EndPoint endpoint,
java.lang.String node,
java.lang.String server,
java.lang.String opName,
java.lang.Object[] params,
java.lang.String[] signature,
java.lang.String epArgs
)
endpoint
-
The target endpointnode
-
node nameserver
-
server nameopName
-
operation nameparams
-
Parameters for the operationsignature
-
Signature of the operationepArgs
-
Arguments for the endpointpublic void processMessagesFromPGCEndpoint(java.util.List messages
)
messages
-
List of job status updatespublic void processPGCEndpointStatusUpdate(com.ibm.ws.gridcontainer.communication.HeartBeatMessage msg
)
msg
-
Heat beatpublic com.ibm.ws.longrun.EndPoint processJobWithoutDispatch(com.ibm.ws.longrun.Job job,
java.lang.String node,
java.lang.String server
)
job
-
Jobnode
-
nodeserver
-
serverpublic java.lang.String IOAPAR_getJobLogPartFromPGCEndpoint(java.lang.String jobId,
java.lang.String partNo,
com.ibm.ws.longrun.EndPoint endpoint,
java.lang.String partNo,
java.lang.String metaData
)
jobId
-
Job id whoose part is requestedpartNo
-
Job log part requestedendpoint
-
Endpoint where job is runningpartNo
-
Job log part requestedmetaData
-
Metadata of Job log part requestedpublic void notifyGAPAboutJobClassCapacityUpdate(java.lang.String jobClass,
java.lang.Integer newCapacityCount
)
jobClass
-
job classnewCapacityCount
-
countpublic void resetDetectionRunFlag(java.lang.Boolean flag
)
flag
-
true or false