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 |
Operation Detail |
---|
public java.lang.String init()
Initializes LRS Component
administrator
operator
public void uninit()
Uninitializes LRS Component
administrator
operator
public void deregister()
Deregisters MBean
administrator
operator
public void createJobStatus(
java.lang.String jobid
)
Publishes a job's status to the Bulletin Board
jobid
-
Job ID
administrator
operator
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
jobid
-
Job ID node
-
node name appServer
-
server name jobType
-
job type
administrator
operator
public void EPSRemove(
java.lang.String jobid
)
Removes a job from the EPS
jobid
-
Job ID
administrator
operator
public java.lang.String getJobID(
java.lang.String jobName
)
Gets a job id assigned to a new job
jobName
-
Job name
administrator
operator
public void incrementJobLogCount(
java.lang.String extendedSection
)
Increments the job log counter
extendedSection
-
Section
administrator
operator
public void decrementJobLogCount(
java.lang.String extendedSection
)
Decrements the job log counter
extendedSection
-
Section
administrator
operator
public java.lang.String getSubDirectory()
Gets the job log subdirectory
administrator
operator
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
xJCL
-
xJCL jobid
-
Job ID submitter
-
Job Submitter ID
administrator
operator
public java.lang.Boolean queue(
com.ibm.ws.longrun.Job job
)
Queues job to GAPAgent
job
-
Job to be dispatched
administrator
operator
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
node
-
node of target server
-
target server opName
-
operation parms
-
parms signature
-
signature of parms epArgs
-
arguments for EPS
administrator
operator
public java.lang.String findBestNodeToDisable(
java.lang.String nodeGroupName
)
Finds the best Node to Disable in a NodeGroup
nodeGroupName
-
the Node Group
administrator
operator
public java.lang.String findBestLocation(
java.lang.String dcMemberName,
java.lang.String oldNodeGroupName,
java.lang.Integer healthCondition
)
Finds the best Node
dcMemberName
-
the DC Name oldNodeGroupName
-
the Node Group Name healthCondition
-
the health indicator
administrator
operator
public void createDJQ()
Creates a Delayed Job Queuer in the CR
administrator
operator
public void createDJQAlarm()
Creates an AlarmManager alarm in the CR for the Delayed Job Queuer
administrator
operator
public void djqAdd(
com.ibm.ws.longrun.Job job
)
adds an element to the Delayed Job Queuer in the CR
job
-
the Job to add
administrator
operator
public void djqRemove(
java.lang.String jobID
)
Remove an element from the Delayed Job Queuer in the CR
jobID
-
The Job ID to Remove
administrator
operator
public java.lang.Integer djqSize()
returns the size of the Delayed Job Queue
administrator
operator
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
reqId
-
name of request nextStartTime
-
alarm activation time rrAL
-
listener for this alarm
administrator
operator
public com.ibm.ws.batch.RecurringRequestAlarmListener createRecurringRequestListener(
com.ibm.ws.batch.RecurringRequestDO rrDO
)
Creates an alarm listener for Recurring Request Alarm in the CR
rrDO
-
Recurring Request Data Object
administrator
operator
public void cancelRecurringRequestAlarm(
java.lang.String reqId
)
Cancels a Recurring Request Alarm alarm in the CR
reqId
-
name of request
administrator
operator
public void recreateRecurringRequestAlarms(
com.ibm.ws.batch.RecurringRequestDO[] rrDO
)
Creates an alarm in the CR to reinit existing Recurring Requests
rrDO
-
recurring request data objects
administrator
operator
public void createJobStatusSubject(
com.ibm.ws.batch.JobStatusDO[] jsDO
)
createJobStatusSubject
jsDO
-
array of job status data object
administrator
operator
public void dsjQueueAdd(
com.ibm.ws.batch.DelayedSubmitJob dsj
)
dsjQueueAdd
dsj
-
name of delayed submit job to add
administrator
operator
public void dsjQueueRemove(
com.ibm.ws.batch.DelayedSubmitJob dsj
)
dsjQueueRemove
dsj
-
name of delayed submit job to remove
administrator
operator
public void displayDSJQueueContents()
displayDSJQueueContents
administrator
operator
public void createRecurringRequest(
com.ibm.ws.batch.RecurringRequestDO rrDO,
java.lang.Long durationToStart
)
createRecurringRequest
rrDO
-
recurring request data object durationToStart
-
duration to start recurring jobs
administrator
operator
public void removeJobStatusSubscription(
java.lang.String jobID
)
Invoke Global Job Status listener to remove a job status Subscription
jobID
-
jobid
administrator
operator
public void cleanupJobClassInfo(
java.util.ArrayList jobsToRemoveList
)
Clean up job calss info.
jobsToRemoveList
-
List of jobs.
administrator
operator
public void invokeGridEndpoint(
java.lang.String opName,
java.lang.String jobID
)
Perform operation on Grid Utility job.
opName
-
Operation Type. jobID
-
Job ID.
administrator
operator
public java.lang.Boolean isApplicationInstalled(
java.lang.String applicationName
)
Verify if the application is installed
applicationName
-
Name of the application
administrator
operator
public java.lang.Boolean isSchedulerActive(
java.lang.String schedulerNameInBBformat
)
Verify if the a scheduler is active
schedulerNameInBBformat
-
Scheduler Name In BB format
administrator
operator
public com.ibm.ws.longrun.EndPoint getGAPEndpoint(
java.lang.String endpointName
)
Retrieve an EndPoint object from GAPNodesTable.
endpointName
-
Name of the endpoint (nodeName/serverName)
administrator
operator
public void setJobEndpoint(
java.lang.String jobid,
com.ibm.ws.longrun.EndPoint endpoint
)
Set the selected Endpoint for a job.
jobid
-
Job ID endpoint
-
Selected endpoint
administrator
operator
public void writeSMF(
com.ibm.ws.batch.JobUsageDO[] juDO,
java.lang.Integer recordCount
)
writeSMF
juDO
-
array of job usage data object recordCount
-
count of job usage data objects for ended jobs
administrator
operator
public void removeXJCLJobFromCache(
java.lang.String jobId
)
removeXJCLJobFromCache
jobId
-
job id to remove from cache
administrator
operator
public java.lang.String[] getJobLogPartListFromPGCEndpoint(
java.lang.String jobId,
com.ibm.ws.longrun.EndPoint endpoint
)
Get the job log parts for the given job
jobId
-
Job id whoose parts are requested endpoint
-
Endpoint where job is running
administrator
operator
public java.lang.String getJobLogPartFromPGCEndpoint(
java.lang.String jobId,
java.lang.String partNo,
com.ibm.ws.longrun.EndPoint endpoint
)
Get the String corresponding to the job log part
jobId
-
Job id whoose part is requested partNo
-
Job log part requested endpoint
-
Endpoint where job is running
administrator
operator
public void updateOwningSchedulerOnPGCEndpoint(
java.util.Map endpointToJobMap,
java.lang.String schedulerName
)
Inform the Endpoint of the new owner of the given list of jobs
endpointToJobMap
-
endpoint to Job map schedulerName
-
The new owning scheduler
administrator
operator
public 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
)
Invoke the given command on the given PGC endpoint
endpoint
-
The target endpoint node
-
node name server
-
server name opName
-
operation name params
-
Parameters for the operation signature
-
Signature of the operation epArgs
-
Arguments for the endpoint
administrator
operator
public void processMessagesFromPGCEndpoint(
java.util.List messages
)
Process job status messages from PGC endpoint
messages
-
List of job status updates
administrator
operator
public void processPGCEndpointStatusUpdate(
com.ibm.ws.gridcontainer.communication.HeartBeatMessage msg
)
Process heart beat message from PGC endpoint
msg
-
Heat beat
administrator
operator
public com.ibm.ws.longrun.EndPoint processJobWithoutDispatch(
com.ibm.ws.longrun.Job job,
java.lang.String node,
java.lang.String server
)
Process job without dispatch
job
-
Job node
-
node server
-
server
administrator
operator