Name | Signature and Synopsis |
---|---|
createScheduler | void createScheduler(String schedulerName, long pollInterval, long refreshAhead) Creates a cluster wide scheduler for time dependent jobs |
createWorkManager | void createWorkManager(String name, int threadPool) Creates a work manager to schedule background jobs |
getAgentId | int getAgentId() Returns the unique id of the agent |
getAgentName | Sring getAgentName() Returns the agent name |
getClusterName | Sring getClusterName() Returns the name of the BE cluster that this agent is connected |
getSiteId | long getSiteId() Returns the site-id of the cluster |
isEventRecovered | boolean isEventRecovered(SimpleEvent evt) This function returns true if the passed event is received from another agent in the cluster. The function will return false if the event was created in this agent. |
registerStateMachineTimeoutCallback | void registerStateMachineTimeoutCallback(String entityURI, String ruleFunctionURI) Register a rule function to pre-process state machine timeouts. The pre-processor should be used to load and/or lock associated objects. |
scheduleEvent | void scheduleEvent(String schedulerName, String workKey, SimpleEvent et, long scheduledTime) Schedules a simple event to be sent to the default destination after scheduledTime |
stopWorkManager | void stopWorkManager(String name) Shuts down the work manager. This call will wait for all the current jobs to finish |