SchedulerCR MBean

Partial ObjectName:
WebSphere:*,type=SchedulerCR


MBean SchedulerCR

z/OS SR-CR hopper for LongRunning Scheduler


Operation Summary
java.lang.Stringinit()
           Initializes LRS Component
voiduninit()
           Uninitializes LRS Component
voidderegister()
           Deregisters MBean
voidcreateJobStatus(java.lang.String jobid)
           Publishes a job's status to the Bulletin Board
voidEPSComplete(java.lang.String jobid, java.lang.String node, java.lang.String appServer, java.lang.String jobType)
           Notifies the EPS of a job's ending status
voidEPSRemove(java.lang.String jobid)
           Removes a job from the EPS
java.lang.StringgetJobID(java.lang.String jobName)
           Gets a job id assigned to a new job
java.lang.Booleanschedule(java.lang.String xJCL, java.lang.String jobid, java.lang.String submitter)
           Gets a job id assigned to a new job
voidinvokeEndpoint(java.lang.String node, java.lang.String server, java.lang.String opName, java.lang.Object[] parms, java.lang.String[] signature, java.lang.String epArgs)
           Invokes the Endpoint Web Service
java.lang.StringfindBestNodeToDisable(java.lang.String nodeGroupName)
           Finds the best Node to Disable in a NodeGroup
java.lang.StringfindBestLocation(java.lang.String dcMemberName, java.lang.String oldNodeGroupName, java.lang.Integer healthCondition)
           Finds the best Node
voidcreateDJQ()
           Creates a Delayed Job Queuer in the CR
voidcreateDJQAlarm()
           Creates an AlarmManager alarm in the CR for the Delayed Job Queuer
voiddjqAdd(com.ibm.ws.longrun.Job job)
           adds an element to the Delayed Job Queuer in the CR
voiddjqRemove(java.lang.String jobID)
           Remove an element from the Delayed Job Queuer in the CR
java.lang.IntegerdjqSize()
           returns the size of the Delayed Job Queue
voidcreateRecurringRequestAlarm(java.lang.String reqId, java.lang.Long nextStartTime, com.ibm.ws.batch.RecurringRequestAlarmListener rrAL)
           Creates an AlarmManager alarm in the CR for Recurring Request
com.ibm.ws.batch.RecurringRequestAlarmListenercreateRecurringRequestListener(com.ibm.ws.batch.RecurringRequestDO rrDO)
           Creates an alarm listener for Recurring Request Alarm in the CR
voidcancelRecurringRequestAlarm(java.lang.String reqId)
           Cancels a Recurring Request Alarm alarm in the CR
voidrecreateRecurringRequestAlarms(com.ibm.ws.batch.RecurringRequestDO[] rrDO)
           Creates an alarm in the CR to reinit existing Recurring Requests
voidcreateJobStatusSubject(com.ibm.ws.batch.JobStatusDO[] jsDO)
           createJobStatusSubject
voiddsjQueueAdd(com.ibm.ws.batch.DelayedSubmitJob dsj)
           dsjQueueAdd
voiddsjQueueRemove(com.ibm.ws.batch.DelayedSubmitJob dsj)
           dsjQueueRemove
voiddisplayDSJQueueContents()
           displayDSJQueueContents
voidcreateRecurringRequest(com.ibm.ws.batch.RecurringRequestDO rrDO, java.lang.Long durationToStart)
           createRecurringRequest
voidremoveJobStatusSubject(java.lang.String jobID)
           removeJobStatusSubject
voidcleanupJobClassInfo(java.util.ArrayList jobsToRemoveList)
           Clean up job calss info.
voidinvokeGridEndpoint(java.lang.String opName, java.lang.String jobID)
           Perform operation on Grid Utility job.
java.lang.BooleanisApplicationInstalled(java.lang.String applicationName)
           Verify if the application is installed
java.lang.BooleanisSchedulerActive(java.lang.String schedulerNameInBBformat)
           Verify if the a scheduler is active
com.ibm.ws.longrun.EndPointgetGAPEndpoint(java.lang.String endpointName)
           Retrieve an EndPoint object from GAPNodesTable.
voidwriteSMF(com.ibm.ws.batch.JobUsageDO[] juDO, java.lang.Integer recordCount)
           writeSMF

Operation Detail

init

public java.lang.String init()
Initializes LRS Component

uninit

public void uninit()
Uninitializes LRS Component

deregister

public void deregister()
Deregisters MBean

createJobStatus

public void createJobStatus(java.lang.String jobid)
Publishes a job's status to the Bulletin Board
Parameters:
jobid - Job ID

EPSComplete

public void EPSComplete(java.lang.String jobid, java.lang.String node, java.lang.String appServer, java.lang.String jobType)
Notifies the EPS of a job's ending status
Parameters:
jobid - Job ID
node - node name
appServer - server name
jobType - job type

EPSRemove

public void EPSRemove(java.lang.String jobid)
Removes a job from the EPS
Parameters:
jobid - Job ID

getJobID

public java.lang.String getJobID(java.lang.String jobName)
Gets a job id assigned to a new job
Parameters:
jobName - Job name

schedule

public java.lang.Boolean schedule(java.lang.String xJCL, java.lang.String jobid, java.lang.String submitter)
Gets a job id assigned to a new job
Parameters:
xJCL - xJCL
jobid - Job ID
submitter - Job Submitter ID

invokeEndpoint

public 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)
Invokes the Endpoint Web Service
Parameters:
node - node of target
server - target server
opName - operation
parms - parms
signature - signature of parms
epArgs - arguments for EPS

findBestNodeToDisable

public java.lang.String findBestNodeToDisable(java.lang.String nodeGroupName)
Finds the best Node to Disable in a NodeGroup
Parameters:
nodeGroupName - the Node Group

findBestLocation

public java.lang.String findBestLocation(java.lang.String dcMemberName, java.lang.String oldNodeGroupName, java.lang.Integer healthCondition)
Finds the best Node
Parameters:
dcMemberName - the DC Name
oldNodeGroupName - the Node Group Name
healthCondition - the health indicator

createDJQ

public void createDJQ()
Creates a Delayed Job Queuer in the CR

createDJQAlarm

public void createDJQAlarm()
Creates an AlarmManager alarm in the CR for the Delayed Job Queuer

djqAdd

public void djqAdd(com.ibm.ws.longrun.Job job)
adds an element to the Delayed Job Queuer in the CR
Parameters:
job - the Job to add

djqRemove

public void djqRemove(java.lang.String jobID)
Remove an element from the Delayed Job Queuer in the CR
Parameters:
jobID - The Job ID to Remove

djqSize

public java.lang.Integer djqSize()
returns the size of the Delayed Job Queue

createRecurringRequestAlarm

public void createRecurringRequestAlarm(java.lang.String reqId, java.lang.Long nextStartTime, com.ibm.ws.batch.RecurringRequestAlarmListener rrAL)
Creates an AlarmManager alarm in the CR for Recurring Request
Parameters:
reqId - name of request
nextStartTime - alarm activation time
rrAL - listener for this alarm

createRecurringRequestListener

public com.ibm.ws.batch.RecurringRequestAlarmListener createRecurringRequestListener(com.ibm.ws.batch.RecurringRequestDO rrDO)
Creates an alarm listener for Recurring Request Alarm in the CR
Parameters:
rrDO - Recurring Request Data Object

cancelRecurringRequestAlarm

public void cancelRecurringRequestAlarm(java.lang.String reqId)
Cancels a Recurring Request Alarm alarm in the CR
Parameters:
reqId - name of request

recreateRecurringRequestAlarms

public void recreateRecurringRequestAlarms(com.ibm.ws.batch.RecurringRequestDO[] rrDO)
Creates an alarm in the CR to reinit existing Recurring Requests
Parameters:
rrDO - recurring request data objects

createJobStatusSubject

public void createJobStatusSubject(com.ibm.ws.batch.JobStatusDO[] jsDO)
createJobStatusSubject
Parameters:
jsDO - array of job status data object

dsjQueueAdd

public void dsjQueueAdd(com.ibm.ws.batch.DelayedSubmitJob dsj)
dsjQueueAdd
Parameters:
dsj - name of delayed submit job to add

dsjQueueRemove

public void dsjQueueRemove(com.ibm.ws.batch.DelayedSubmitJob dsj)
dsjQueueRemove
Parameters:
dsj - name of delayed submit job to remove

displayDSJQueueContents

public void displayDSJQueueContents()
displayDSJQueueContents

createRecurringRequest

public void createRecurringRequest(com.ibm.ws.batch.RecurringRequestDO rrDO, java.lang.Long durationToStart)
createRecurringRequest
Parameters:
rrDO - recurring request data object
durationToStart - duration to start recurring jobs

removeJobStatusSubject

public void removeJobStatusSubject(java.lang.String jobID)
removeJobStatusSubject
Parameters:
jobID - jobid

cleanupJobClassInfo

public void cleanupJobClassInfo(java.util.ArrayList jobsToRemoveList)
Clean up job calss info.
Parameters:
jobsToRemoveList - List of jobs.

invokeGridEndpoint

public void invokeGridEndpoint(java.lang.String opName, java.lang.String jobID)
Perform operation on Grid Utility job.
Parameters:
opName - Operation Type.
jobID - Job ID.

isApplicationInstalled

public java.lang.Boolean isApplicationInstalled(java.lang.String applicationName)
Verify if the application is installed
Parameters:
applicationName - Name of the application

isSchedulerActive

public java.lang.Boolean isSchedulerActive(java.lang.String schedulerNameInBBformat)
Verify if the a scheduler is active
Parameters:
schedulerNameInBBformat - Scheduler Name In BB format

getGAPEndpoint

public com.ibm.ws.longrun.EndPoint getGAPEndpoint(java.lang.String endpointName)
Retrieve an EndPoint object from GAPNodesTable.
Parameters:
endpointName - Name of the endpoint (nodeName/serverName)

writeSMF

public void writeSMF(com.ibm.ws.batch.JobUsageDO[] juDO, java.lang.Integer recordCount)
writeSMF
Parameters:
juDO - array of job usage data object
recordCount - count of job usage data objects for ended jobs

Copyright IBM Corp. 1996 - 2007