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 |
void | processMessagesFromPGCEndpoint( Process job status messages from PGC endpoint |
void | processPGCEndpointStatusUpdate( Process heart beat message from PGC endpoint |
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 |
Operation Detail |
public java.lang.String init()
public void uninit()
public void deregister()
public void createJobStatus(java.lang.String jobid
)
jobid
-
Job ID
public 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 type
public void EPSRemove(java.lang.String jobid
)
jobid
-
Job ID
public java.lang.String getJobID(java.lang.String jobName
)
jobName
-
Job name
public void incrementJobLogCount(java.lang.String extendedSection
)
extendedSection
-
Section
public void decrementJobLogCount(java.lang.String extendedSection
)
extendedSection
-
Section
public 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 ID
public java.lang.Boolean queue(com.ibm.ws.longrun.Job job
)
job
-
Job to be dispatched
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
)
node
-
node of targetserver
-
target serveropName
-
operationparms
-
parmssignature
-
signature of parmsepArgs
-
arguments for EPS
public java.lang.String findBestNodeToDisable(java.lang.String nodeGroupName
)
nodeGroupName
-
the Node Group
public 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 indicator
public void createDJQ()
public void createDJQAlarm()
public void djqAdd(com.ibm.ws.longrun.Job job
)
job
-
the Job to add
public void djqRemove(java.lang.String jobID
)
jobID
-
The Job ID to Remove
public 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 alarm
public com.ibm.ws.batch.RecurringRequestAlarmListener createRecurringRequestListener(com.ibm.ws.batch.RecurringRequestDO rrDO
)
rrDO
-
Recurring Request Data Object
public void cancelRecurringRequestAlarm(java.lang.String reqId
)
reqId
-
name of request
public void recreateRecurringRequestAlarms(com.ibm.ws.batch.RecurringRequestDO[] rrDO
)
rrDO
-
recurring request data objects
public void createJobStatusSubject(com.ibm.ws.batch.JobStatusDO[] jsDO
)
jsDO
-
array of job status data object
public void dsjQueueAdd(com.ibm.ws.batch.DelayedSubmitJob dsj
)
dsj
-
name of delayed submit job to add
public void dsjQueueRemove(com.ibm.ws.batch.DelayedSubmitJob dsj
)
dsj
-
name of delayed submit job to remove
public void displayDSJQueueContents()
public void createRecurringRequest(com.ibm.ws.batch.RecurringRequestDO rrDO,
java.lang.Long durationToStart
)
rrDO
-
recurring request data objectdurationToStart
-
duration to start recurring jobs
public void removeJobStatusSubscription(java.lang.String jobID
)
jobID
-
jobid
public 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 application
public void processMessagesFromPGCEndpoint(java.util.List messages
)
messages
-
List of job status updates
public void processPGCEndpointStatusUpdate(com.ibm.ws.gridcontainer.communication.HeartBeat msg
)
msg
-
Heat beat
public java.lang.Boolean isSchedulerActive(java.lang.String schedulerNameInBBformat
)
schedulerNameInBBformat
-
Scheduler Name In BB format
public 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 endpoint
public 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 jobs
public void removeXJCLJobFromCache(java.lang.String jobId
)
jobId
-
job id to remove from cache
public 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 running
public 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 running
public void updateOwningSchedulerOnPGCEndpoint(java.util.Map endpointToJobMap,
java.lang.String schedulerName
)
endpointToJobMap
-
endpoint to Job mapschedulerName
-
The new owning scheduler
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
)
endpoint
-
The target endpointnode
-
node nameserver
-
server nameopName
-
operation nameparams
-
Parameters for the operationsignature
-
Signature of the operationepArgs
-
Arguments for the endpoint