com.qoretechnologies.qorus.workflow.QorusEventArrayStep Class Reference

Inheritance diagram for com.qoretechnologies.qorus.workflow.QorusEventArrayStep:

Public Member Methods
abstract Object[]	array () throws Throwable
abstract void	primary (Object array_arg) throws Throwable
Public Member Methods inherited from com.qoretechnologies.qorus.workflow.QorusEventStepBase
void	bindEvent (String eventkey) throws Throwable
void	bindEventUnposted (String eventkey) throws Throwable
void	skipEvent () throws Throwable
Public Member Methods inherited from com.qoretechnologies.qorus.workflow.QorusStepBase
HashMap< String, Object >	getDefaultStepData ()
HashMap< String, Object >	getStepMetadata ()
final HashMap< String, ConfigItem >	getConfigItems ()

Additional Inherited Members
Static Public Member Methods inherited from com.qoretechnologies.qorus.workflow.QorusStepBase
static void	updateStepData (Map< String, Object > new_data) throws Throwable
static void	deleteStepDataKey (String... keylist) throws Throwable
static Object	getStepData (String key) throws Throwable
static HashMap< String, Object >	getStepData (String arg0, String... args) throws Throwable
static HashMap< String, Object >	getStepData () throws Throwable
static Object	getStepDataArgs (String... keylist) throws Throwable
Static Public Member Methods inherited from com.qoretechnologies.qorus.workflow.WorkflowApi
static String	generateUniqueKey () throws Throwable
static void	stepError (String err, Object info, int retry_delay_secs) throws Throwable
static void	stepError (String err, int retry_delay_secs) throws Throwable
static void	stepError (String err, Object info) throws Throwable
static void	stepError (String err) throws Throwable
static void	stepWarning (String err, Object info) throws Throwable
static void	stepWarning (String err) throws Throwable
static void	setRetryDelay (int secs) throws Throwable
static void	updateDynamicData (HashMap< String, Object > hash) throws Throwable
static void	deleteDynamicDataKey (String... keys) throws Throwable
static void	deleteDynamicDataKey (String key) throws Throwable
static Object	getDynamicData (String key) throws Throwable
static HashMap< String, Object >	getDynamicData (String... keys) throws Throwable
static HashMap< String, Object >	getDynamicData () throws Throwable
static Object	getStaticData (String key) throws Throwable
static HashMap< String, Object >	getStaticData (String... keys) throws Throwable
static HashMap< String, Object >	getStaticData () throws Throwable
static void	updateTempData (HashMap< String, Object > hash) throws Throwable
static Object	getTempData (String key) throws Throwable
static HashMap< String, Object >	getTempData (String... keys) throws Throwable
static HashMap< String, Object >	getTempData () throws Throwable
static void	deleteTempDataKey (String... keys) throws Throwable
static void	updateSensitiveData (String skey, String svalue, HashMap< String, Object > hash, String[] aliases, HashMap< String, Object > meta) throws Throwable
static void	updateSensitiveData (String skey, String svalue, HashMap< String, Object > hash, String[] aliases) throws Throwable
static void	updateSensitiveData (String skey, String svalue, HashMap< String, Object > hash) throws Throwable
static void	updateSensitiveDataFromAlias (String alias, HashMap< String, Object > hash, HashMap< String, Object > meta) throws Throwable
static void	updateSensitiveDataFromAlias (String alias, HashMap< String, Object > hash) throws Throwable
static HashMap< String, Object >	getSensitiveMetadata (String skey, String svalue) throws Throwable
static HashMap< String, Object >	getSensitiveMetadataFromAlias (String alias) throws Throwable
static HashMap< String, Object >	getSensitiveData (String skey, String svalue, String... keys) throws Throwable
static Object	getSensitiveData (String skey, String svalue, String key) throws Throwable
static HashMap< String, Object >	getSensitiveData (String skey, String svalue) throws Throwable
static HashMap< String, Object >	getSensitiveDataFromAlias (String alias, String... keys) throws Throwable
static HashMap< String, Object >	getSensitiveDataFromAlias (String alias, String key) throws Throwable
static HashMap< String, Object >	getSensitiveDataFromAlias (String alias) throws Throwable
static HashMap< String, Object >	getSensitiveDataAliases () throws Throwable
static boolean	deleteSensitiveData (String skey, String svalue) throws Throwable
static boolean	deleteSensitiveDataKey (String skey, String svalue, String... keys) throws Throwable
static HashMap< String, Object >	getSensitiveDataKeyValues () throws Throwable
static void	deleteInstanceDataKey (String... keys) throws Throwable
static void	updateInstanceData (HashMap< String, Object > hash) throws Throwable
static HashMap< String, Object >	getInstanceData () throws Throwable
static Object	getInstanceData (String key) throws Throwable
static HashMap< String, Object >	getInstanceData (String... args) throws Throwable
static boolean	stepExecuted (String stepname) throws Throwable
static String	getStepStatus (String stepname) throws Throwable
static HashMap< String, Object >	getStepInfo () throws Throwable
static HashMap< String, Object >	getWorkflowInstanceData () throws Throwable
static Object	getWorkflowInstanceData (String key) throws Throwable
static HashMap< String, Object >	getWorkflowInstanceData (String... args) throws Throwable
static void	setOrderKeys (HashMap< String, Object > h, boolean truncate) throws Throwable
static void	setOrderKeys (HashMap< String, Object > h) throws Throwable
static void	setOrderKey (String key, String value, boolean truncate) throws Throwable
static void	setOrderKey (String key, String value) throws Throwable
static void	setOrderKey (String key, String[] values, boolean truncate) throws Throwable
static void	setOrderKey (String key, Object... values) throws Throwable
static void	appendOrderKeys (HashMap< String, Object > h, boolean truncate) throws Throwable
static void	appendOrderKeys (HashMap< String, Object > h) throws Throwable
static void	appendOrderKeys (String key, String value, boolean truncate) throws Throwable
static void	appendOrderKeys (String key, Object... values) throws Throwable
static Object	getOrderKeys (String key) throws Throwable
static HashMap< String, Object >	getOrderKeys (String... keys) throws Throwable
static HashMap< String, Object >	getOrderKeys () throws Throwable
static HashMap< String, Object >	getWorkflowMetadata () throws Throwable
static void	setBlocked () throws Throwable
static HashMap< String, Object >[]	getOrderNotes (int count) throws Throwable
static HashMap< String, Object >[]	getOrderNotes () throws Throwable
static void	addOrderNote (String notestr) throws Throwable
static void	setCustomStatus (String stat) throws Throwable
static void	rescheduleOrder (ZonedDateTime scheduled) throws Throwable
static void	reprioritizeOrder (int prio) throws Throwable
static void	leaveParentFeedback (String key, Object value) throws Throwable
static Object	getChildFeedback (String key) throws Throwable
static HashMap< String, Object >	getChildFeedback () throws Throwable
static Integer	parentWfiid () throws Throwable
static HashMap< String, Object >	getOption (String... keys) throws Throwable
static Object	getOption (String key) throws Throwable
static HashMap< String, Object >	getOption () throws Throwable
static void	setOption (HashMap< String, Object > hash) throws Throwable
static void	setOption (String option, Object value) throws Throwable
static Integer	getWfiid () throws Throwable
static int	sleep (int arg) throws Throwable
static int	usleep (int arg) throws Throwable
static int	usleep (QoreRelativeTime arg) throws Throwable
static Object	getConfigItemValue (String item, HashMap< String, Object > local_context, boolean expand_complex_values) throws Throwable
static Object	getConfigItemValue (String item, HashMap< String, Object > local_context) throws Throwable
static Object	getConfigItemValue (String item) throws Throwable
static HashMap< String, Object >	getConfigItemHash (HashMap< String, Object > local_context) throws Throwable
static HashMap< String, Object >	getConfigItemHash () throws Throwable
Static Public Member Methods inherited from com.qoretechnologies.qorus.UserApi
static Integer	auditUserEvent (String user_event, String info1, String info2) throws Throwable
static Integer	auditUserEvent (String user_event, String info1) throws Throwable
static Integer	auditUserEvent (String user_event) throws Throwable
static boolean	auditCheckEventString (String opt) throws Throwable
static boolean	auditCheckEvent (int opt) throws Throwable
static int	auditGetMask () throws Throwable
static int	postUserEvent (String severity, Object info) throws Throwable
static HashMap< String, Object >	runtimeProperties () throws Throwable
static Object	callNetworkApi (String call, Object... args) throws Throwable
static Object	callNetworkApiArgs (String call, Object[] args) throws Throwable
static Object	callNetworkApiArgsWithAuthentication (String user, String pass, String call, Object[] args) throws Throwable
static Object	callRestApi (String method, String path, HashMap< String, Object > body_args) throws Throwable
static Object	callRestApi (String method, String path) throws Throwable
static Object	callRestApiWithAuthentication (String user, String pass, String method, String path, HashMap< String, Object > body_args) throws Throwable
static AbstractTable	getSqlTable (String datasource, String table_name) throws Throwable
static AbstractTable	getSqlTable (AbstractDatasource datasource, String table_name) throws Throwable
static HashMap< String, Object >	getSqlCacheInfo () throws Throwable
static void	clearSqlTableCache (String datasource, String table_name) throws Throwable
static void	clearSqlTableCache (String datasource) throws Throwable
static Object	getValueMap (String mapname, String key) throws Throwable
static HashMap< String, Object >[]	getValueMaps () throws Throwable
static boolean	postSlaEventSuccess (String sla, float value) throws Throwable
static boolean	postSlaEventError (String sla, float value, String err, String desc) throws Throwable
static void	flushSlaEvents () throws Throwable
static HashMap< String, Object >	getSystemServiceInfo (String name) throws Throwable
static HashMap< String, Object >	getServiceInfo (String type, String name) throws Throwable
static HashMap< String, Object >[]	getRunningWorkflowList (String name, String ver) throws Throwable
static HashMap< String, Object >[]	getRunningWorkflowList (String name) throws Throwable
static HashMap< String, Object >[]	getRunningWorkflowList () throws Throwable
static HashMap< String, Object >	getRunningWorkflowInfo (int id) throws Throwable
static int	createOrder (String name, String version, HashMap< String, Object > params) throws Throwable
static int	createOrder (String name, String version, HashMap< String, Object > params, String status) throws Throwable
static int	createOrder (String name, HashMap< String, Object > params) throws Throwable
static int	createOrder (String name, HashMap< String, Object > params, String status) throws Throwable
static int	createRemoteOrder (String remote, String name, String version, HashMap< String, Object > params, String status, boolean register_dependency) throws Throwable
static int	createRemoteOrder (String remote, String name, String version, HashMap< String, Object > params, String status) throws Throwable
static int	createRemoteOrder (String remote, String name, String version, HashMap< String, Object > params) throws Throwable
static int	createRemoteOrder (String remote, String name, HashMap< String, Object > params, String status, boolean register_dependency) throws Throwable
static int	createRemoteOrder (String remote, String name, HashMap< String, Object > params, String status) throws Throwable
static int	createRemoteOrder (String remote, String name, HashMap< String, Object > params) throws Throwable
static HashMap< String, Object >	execSynchronousWorkflow (String name, String version, HashMap< String, Object > sdata, HashMap< String, Object > opts, HashMap< String, Object > ddata, int priority, HashMap< String, Object > orderkeys, String external_order_instanceid, int parent_workflow_instanceid) throws Throwable
static HashMap< String, Object >	execSynchronousWorkflow (String name, HashMap< String, Object > sdata, HashMap< String, Object > opts, HashMap< String, Object > ddata, int priority, HashMap< String, Object > orderkeys, String external_order_instanceid, int parent_workflow_instanceid) throws Throwable
static HashMap< String, Object >	execSynchronousWorkflow (String name, HashMap< String, Object > sdata, HashMap< String, Object > opts, HashMap< String, Object > ddata, int priority, HashMap< String, Object > orderkeys, String external_order_instanceid) throws Throwable
static HashMap< String, Object >	execSynchronousWorkflow (String name, HashMap< String, Object > sdata, HashMap< String, Object > opts, HashMap< String, Object > ddata, int priority, HashMap< String, Object > orderkeys) throws Throwable
static HashMap< String, Object >	execSynchronousWorkflow (String name, HashMap< String, Object > sdata, HashMap< String, Object > opts, HashMap< String, Object > ddata, int priority) throws Throwable
static HashMap< String, Object >	execSynchronousWorkflow (String name, HashMap< String, Object > sdata, HashMap< String, Object > opts, HashMap< String, Object > ddata) throws Throwable
static HashMap< String, Object >	execSynchronousWorkflow (String name, HashMap< String, Object > sdata, HashMap< String, Object > opts) throws Throwable
static HashMap< String, Object >	execSynchronousWorkflow (String name, HashMap< String, Object > sdata) throws Throwable
static HashMap< String, Object >	getQorusOptions () throws Throwable
static Object	getQorusOptions (String opt) throws Throwable
static HashMap< String, Object >	getQorusOptions (String... opts) throws Throwable
static HashMap< String, Object >	getQorusOptionsArgs (String[] opts) throws Throwable
static HashMap< String, Object >	getQorusOptionInfo () throws Throwable
static HashMap< String, Object >	getQorusOptionInfoArgs (String[] args) throws Throwable
static HashMap< String, Object >	getActiveJobs () throws Throwable
static Object	getUserConnection (String name, boolean connect, boolean register_dependency, HashMap< String, Object > rtopts) throws Throwable
static Object	getUserConnection (String name, boolean connect, boolean register_dependency) throws Throwable
static Object	getUserConnection (String name, boolean connect) throws Throwable
static Object	getUserConnection (String name) throws Throwable
static HashMap< String, Object >	getUserConnectionTags (String name) throws Throwable
static DatasourcePool	getDatasourcePool (String name, boolean register_dependency) throws Throwable
static DatasourcePool	getDatasourcePool (String name) throws Throwable
static HashMap< String, Object >	getDatasourceInfo (String name) throws Throwable
static QorusSystemRestHelper	getRemoteRestConnection (String name, boolean connect, boolean register_dependency) throws Throwable
static QorusSystemRestHelper	getRemoteRestConnection (String name, boolean connect) throws Throwable
static QorusSystemRestHelper	getRemoteRestConnection (String name) throws Throwable
static void	raiseTransientAlert (String alert, String reason, HashMap< String, Object > info) throws Throwable
static void	raiseTransientAlert (String alert, String reason) throws Throwable
static String	qorusGetLocalUrl (String username, String password) throws Throwable
static String	qorusGetLocalUrl () throws Throwable
static HashMap< String, Object >	blockOrder (int wfiid) throws Throwable
static HashMap< String, Object >	unblockOrder (int wfiid, HashMap< String, Object > tempdata, HashMap< String, Object > orderkeys) throws Throwable
static HashMap< String, Object >	unblockOrder (int wfiid, HashMap< String, Object > tempdata) throws Throwable
static HashMap< String, Object >	unblockOrder (int wfiid) throws Throwable
static HashMap< String, Object >	cancelOrder (int wfiid) throws Throwable
static HashMap< String, Object >	uncancelOrder (int wfiid, HashMap< String, Object > tempdata) throws Throwable
static HashMap< String, Object >	uncancelOrder (int wfiid) throws Throwable
static HashMap< String, Object >	getUserContextInfo () throws Throwable
static String	getContextUserName () throws Throwable
static Object	getInterfaceConfigItemValue (String item, HashMap< String, Object > local_context, boolean expand_complex_values) throws Throwable
static Object	getInterfaceConfigItemValue (String item, HashMap< String, Object > local_context) throws Throwable
static Object	getInterfaceConfigItemValue (String item) throws Throwable
static HashMap< String, Object >	getInterfaceConfigItemHash (HashMap< String, Object > local_context) throws Throwable
static HashMap< String, Object >	getInterfaceConfigItemHash () throws Throwable
static AbstractDataProvider	getDataProvider (String path) throws Throwable
static AbstractDataProviderType	getQorusType (String type_path) throws Throwable
static AbstractDataProviderType	getTypeFromPath (String path) throws Throwable
static Object	getGlobalConfigItemValue (String item, HashMap< String, Object > local_context, boolean expand_complex_values) throws Throwable
static Object	getGlobalConfigItemValue (String item, HashMap< String, Object > local_context) throws Throwable
static Object	getGlobalConfigItemValue (String item) throws Throwable
static Mapper	getMapper (String name, HashMap< String, Object > rtopts) throws Throwable
static Mapper	getMapper (String name) throws Throwable
static boolean	postSyncEvent (String eventtype, String eventkey) throws Throwable
static int	getSessionId () throws Throwable
static HashMap< String, Object >	getSystemInfo () throws Throwable
static HashMap< String, Object >	propGet () throws Throwable
static HashMap< String, Object >	propGet (String domain) throws Throwable
static HashMap< String, Object >	propGet (String domain, String key) throws Throwable
static String	propUpdate (String domain, String key, Object value) throws Throwable
static void	logFatal (String msg) throws Throwable
static void	logError (String msg) throws Throwable
static void	logWarn (String msg) throws Throwable
static void	logInfo (String msg) throws Throwable
static void	logDebug (String msg) throws Throwable
static void	logTrace (String msg) throws Throwable
static void	logFatal (String msg, Object... args) throws Throwable
static void	logError (String msg, Object... args) throws Throwable
static void	logWarn (String msg, Object... args) throws Throwable
static void	logInfo (String msg, Object... args) throws Throwable
static void	logDebug (String msg, Object... args) throws Throwable
static void	logTrace (String msg, Object... args) throws Throwable
static int	getNextSequenceValue (AbstractDatasource ds, String name) throws Throwable
static int	getNextSequenceValue (String ds, String name) throws Throwable
static String	serializeQorusData (Object d) throws Throwable
static String	serializeQorusDataWithNothing (Object d) throws Throwable
static Object	deserializeQorusData (String data) throws Throwable
static String	restartTransaction (String driver, HashMap< String, Object > ex) throws Throwable
static String	expandOneVariable (String str, String var_context, String var_name, HashMap< String, Object > local_context, boolean expand_complex_values) throws Throwable
static String	expandOneVariable (String str, String var_context, String var_name, HashMap< String, Object > local_context) throws Throwable
static Object	expandTemplatedValue (String str, HashMap< String, Object > local_context, boolean expand_complex_values) throws Throwable
static Object	expandTemplatedValue (String str, HashMap< String, Object > local_context) throws Throwable
static HashMap< String, Object >	bbParseExactlyOneVariable (String str) throws Throwable
static HashMap< String, Object >	getInputData (String field_name, HashMap< String, Object > local_context, HashMap< String, Object > input_data_cfg) throws Throwable
static HashMap< String, Object >	getInputData (HashMap< String, Object > input_data_cfg, HashMap< String, Object > local_context) throws Throwable
static void	updateOutputData (String field_name, Object output_data, HashMap< String, Object > output_data_cfg) throws Throwable
static void	updateOutputData (HashMap< String, Object > all_output_data, HashMap< String, Object > output_data_cfg) throws Throwable
static String	getTextFileFromLocation (String location) throws Throwable
static byte[]	getBinaryFileFromLocation (String location) throws Throwable
static void	startCapturingObjects () throws Throwable
static void	stopCapturingObjects () throws Throwable
static void	saveObjectInObjectCache (QoreObject obj) throws Throwable
static boolean	clearObjectFromObjectCache (QoreObject obj) throws Throwable
static ZonedDateTime	checkObjectCache (QoreObject obj) throws Throwable
static int	getObjectCacheSize () throws Throwable
static int	clearObjectCache () throws Throwable
static int	clearObjectCache (ZonedDateTime cutoff) throws Throwable
static Object	executeFsm (String name, Object arg) throws Throwable
	Executes the given Finite State Machine and returns the final output. More...
static Object	executeFsm (String name) throws Throwable
	Executes the given Finite State Machine and returns the final output. More...
static void	registerFsmAsObserver (String fsm_name, Observable observable, String event_id) throws Throwable
	Registers the given FSM with the given object as an Observer. More...
Static Public Attributes inherited from com.qoretechnologies.qorus.OMQ
static final String	OT_CONSTANT = "CONSTANT"
static final String	OT_CLASS = "CLASS"
static final String	OT_FUNCTION = "FUNCTION"
static final String	ExecNormal = "NORMAL"
static final String	ExecAsync = "ASYNC"
static final String	ExecSubWorkflow = "SUBWORKFLOW"
static final String	ExecEvent = "EVENT"
static final String	SSRunning = "running"
static final String	SSLoaded = "loaded"
static final String	SLNone = "none"
static final String	SLRead = "read"
static final String	SLWrite = "write"
static final String	SQLStatComplete = "C"
static final String	SQLStatError = "E"
static final String	SQLStatWaiting = "W"
static final String	SQLStatInProgress = "I"
static final String	SQLStatIncomplete = "N"
static final String	SQLStatAsyncWaiting = "A"
static final String	SQLStatEventWaiting = "V"
static final String	SQLStatRetry = "R"
static final String	SQLStatCanceled = "X"
static final String	SQLStatReady = "Y"
static final String	SQLStatScheduled = "S"
static final String	SQLStatBlocked = "B"
static final int	LL_CRITICAL = -1
static final int	LL_IMPORTANT = 0
static final int	LL_INFO = 1
static final int	LL_DETAIL_1 = 2
static final int	LL_DETAIL_2 = 3
static final int	LL_DEBUG_1 = 4
static final int	LL_DEBUG_2 = 5
static final int	LL_DEBUG_3 = 6
static final String	WM_Normal = "NORMAL"
static final String	WM_Recovery = "RECOVERY"
static final String	StatComplete = "COMPLETE"
static final String	StatError = "ERROR"
static final String	StatWaiting = "WAITING"
static final String	StatInProgress = "IN-PROGRESS"
static final String	StatIncomplete = "INCOMPLETE"
static final String	StatAsyncWaiting = "ASYNC-WAITING"
static final String	StatEventWaiting = "EVENT-WAITING"
static final String	StatRetry = "RETRY"
static final String	StatCanceled = "CANCELED"
static final String	StatReady = "READY"
static final String	StatScheduled = "SCHEDULED"
static final String	StatBlocked = "BLOCKED"
static final Map< String, String >	StatMap
static final Map< String, String >	SQLStatMap
static final String	ES_Major = "MAJOR"
static final String	ES_Warning = "WARNING"
static final String	CS_Clean = "C"
static final String	CS_RecoveredAuto = "A"
static final String	CS_RecoveredManual = "M"
static final String	QS_Waiting = "WAITING"
static final String	QS_Received = "RECEIVED"
static final String	QS_Error = "ERROR"
static final String	QS_Used = "USED"
static final String	SQL_QS_Waiting = "W"
static final String	SQL_QS_Received = "R"
static final String	SQL_QS_Error = "E"
static final String	SQL_QS_Used = "X"
static final Map< String, String >	QSMap
static final Map< String, String >	SQLQSMap
static final String	QR_LOGIN = "LOGIN"
static final String	QR_SHUTDOWN = "SHUTDOWN"
static final String	QR_WORKFLOW_CONTROL = "WORKFLOW-CONTROL"
static final String	QR_WORKFLOW_EXEC_CONTROL = "WORKFLOW-EXEC-CONTROL"
static final String	QR_START_WORKFLOW = "START-WORKFLOW"
static final String	QR_STOP_WORKFLOW = "STOP-WORKFLOW"
static final String	QR_RESET_WORKFLOW = "RESET-WORKFLOW"
static final String	QR_WORKFLOW_OPTION_CONTROL = "WORKFLOW-OPTION-CONTROL"
static final String	QR_WORKFLOW_ERROR_CONTROL = "WORKFLOW-ERROR-CONTROL"
static final String	QR_WORKFLOW_ORDER_CONTROL = "WORKFLOW-ORDER-CONTROL"
static final String	QR_RETRY_WORKFLOW_ORDER = "RETRY-WORKFLOW-ORDER"
static final String	QR_RESCHEDULE_WORKFLOW_ORDER = "RESCHEDULE-WORKFLOW-ORDER"
static final String	QR_REPRIORITIZE_WORKFLOW_ORDER = "REPRIORITIZE-WORKFLOW-ORDER"
static final String	QR_BLOCK_WORKFLOW_ORDER = "BLOCK-WORKFLOW-ORDER"
static final String	QR_CANCEL_WORKFLOW_ORDER = "CANCEL-WORKFLOW-ORDER"
static final String	QR_SET_WORKFLOW_ORDER_ERROR = "SET-WORKFLOW-ORDER-ERROR"
static final String	QR_SKIP_STEP = "SKIP-STEP"
static final String	QR_SET_ORDER_INFO = "SET-ORDER-INFO"
static final String	QR_POST_WORKFLOW_EVENT = "POST-WORKFLOW-EVENT"
static final String	QR_LOCK_WORKFLOW_ORDER = "LOCK-WORKFLOW-ORDER"
static final String	QR_BREAK_WORKFLOW_ORDER_LOCK = "BREAK-WORKFLOW-ORDER-LOCK"
static final String	QR_EDIT_WORKFLOW_DATA = "EDIT-WORKFLOW-DATA"
static final String	QR_READ_SENSITIVE_DATA = "READ-SENSITIVE-DATA"
static final String	QR_EDIT_SENSITIVE_DATA = "EDIT-SENSITIVE-DATA"
static final String	QR_DELETE_SENSITIVE_DATA = "DELETE-SENSITIVE-DATA"
static final String	QR_SENSITIVE_DATA_CONTROL = "SENSITIVE-DATA-CONTROL"
static final String	QR_EXEC_SYNC_WORKFLOW = "EXEC-SYNC-WORKFLOW"
static final String	QR_SUBMIT_ORDER = "SUBMIT-ORDER"
static final String	QR_SET_STEP_CONFIG = "SET-STEP-CONFIG"
static final String	QR_SET_WORKFLOW_CONFIG = "SET-WORKFLOW-CONFIG"
static final String	QR_SERVICE_CONTROL = "SERVICE-CONTROL"
static final String	QR_LOAD_SERVICE = "LOAD-SERVICE"
static final String	QR_UNLOAD_SERVICE = "UNLOAD-SERVICE"
static final String	QR_RESET_SERVICE = "RESET-SERVICE"
static final String	QR_SET_SERVICE_AUTOSTART = "SET-SERVICE-AUTOSTART"
static final String	QR_SET_SERVICE_OPTIONS = "SET-SERVICE-OPTIONS"
static final String	QR_CALL_USER_SERVICES_RO = "CALL-USER-SERVICES-RO"
static final String	QR_CALL_SYSTEM_SERVICES_RO = "CALL-SYSTEM-SERVICES-RO"
static final String	QR_CALL_USER_SERVICES_RW = "CALL-USER-SERVICES-RW"
static final String	QR_CALL_SYSTEM_SERVICES_RW = "CALL-SYSTEM-SERVICES-RW"
static final String	QR_SET_SERVICE_CONFIG = "SET-SERVICE-CONFIG"
static final String	QR_SERVICE_OPTION_CONTROL = "SERVICE-OPTION-CONTROL"
static final String	QR_USER_CONTROL = "USER-CONTROL"
static final String	QR_RELOAD_RBAC = "RELOAD-RBAC"
static final String	QR_ADD_USER = "ADD-USER"
static final String	QR_MODIFY_USER = "MODIFY-USER"
static final String	QR_DELETE_USER = "DELETE-USER"
static final String	QR_ADD_PERMISSION = "ADD-PERMISSION"
static final String	QR_MODIFY_PERMISSION = "MODIFY-PERMISSION"
static final String	QR_DELETE_PERMISSION = "DELETE-PERMISSION"
static final String	QR_ADD_ROLE = "ADD-ROLE"
static final String	QR_MODIFY_ROLE = "MODIFY-ROLE"
static final String	QR_DELETE_ROLE = "DELETE-ROLE"
static final String	QR_OPTION_CONTROL = "OPTION-CONTROL"
static final String	QR_LOGGER_CONTROL = "LOGGER-CONTROL"
static final String	QR_ROTATE_LOG_FILES = "ROTATE-LOG-FILES"
static final String	QR_MODIFY_LOGGER = "MODIFY-LOGGER"
static final String	QR_DELETE_LOGGER = "DELETE-LOGGER"
static final String	QR_CREATE_LOGGER = "CREATE-LOGGER"
static final String	QR_DATASOURCE_CONTROL = "DATASOURCE-CONTROL"
static final String	QR_READ_DATASOURCE = "READ-DATASOURCE"
static final String	QR_ADD_DATASOURCE = "ADD-DATASOURCE"
static final String	QR_SELECT_DATASOURCE = "SELECT-DATASOURCE"
static final String	QR_MODIFY_DATASOURCE = "MODIFY-DATASOURCE"
static final String	QR_RESET_DATASOURCE = "RESET-DATASOURCE"
static final String	QR_DELETE_DATASOURCE = "DELETE-DATASOURCE"
static final String	QR_RELOAD_DATASOURCE = "RELOAD-DATASOURCE"
static final String	QR_FLUSH_DATASOURCE = "FLUSH-DATASOURCE"
static final String	QR_SQLUTIL_READ = "SQLUTIL-READ"
static final String	QR_SQLUTIL_WRITE = "SQLUTIL-WRITE"
static final String	QR_GROUP_CONTROL = "GROUP-CONTROL"
static final String	QR_ADD_GROUP = "ADD-GROUP"
static final String	QR_MODIFY_GROUP = "MODIFY-GROUP"
static final String	QR_DELETE_GROUP = "DELETE-GROUP"
static final String	QR_MODIFY_GROUP_STATUS = "MODIFY-GROUP-STATUS"
static final String	QR_SERVER_CONTROL = "SERVER-CONTROL"
static final String	QR_SET_PROPERTY = "SET-PROPERTY"
static final String	QR_DELETE_PROPERTY = "DELETE-PROPERTY"
static final String	QR_RELOAD_PROPERTIES = "RELOAD-PROPERTIES"
static final String	QR_START_LISTENER = "START-LISTENER"
static final String	QR_STOP_LISTENER = "STOP-LISTENER"
static final String	QR_JOB_CONTROL = "JOB-CONTROL"
static final String	QR_RUN_JOB = "RUN-JOB"
static final String	QR_MODIFY_JOB_STATUS = "MODIFY-JOB-STATUS"
static final String	QR_MODIFY_JOB_EXPIRY = "MODIFY-JOB-EXPIRY"
static final String	QR_RESCHEDULE_JOB = "RESCHEDULE-JOB"
static final String	QR_RESET_JOB = "RESET-JOB"
static final String	QR_SET_JOB_OPTIONS = "SET-JOB-OPTIONS"
static final String	QR_SET_JOB_CONFIG = "SET-JOB-CONFIG"
static final String	QR_JOB_OPTION_CONTROL = "JOB-OPTION-CONTROL"
static final String	QR_SCHEMA_CONTROL = "SCHEMA-CONTROL"
static final String	QR_USER_CONNECTION_CONTROL = "USER-CONNECTION-CONTROL"
static final String	QR_READ_USER_CONNECTION = "READ-USER-CONNECTION"
static final String	QR_RELOAD_USER_CONNECTION = "RELOAD-USER-CONNECTION"
static final String	QR_ADD_USER_CONNECTION = "ADD-USER-CONNECTION"
static final String	QR_MODIFY_USER_CONNECTION = "MODIFY-USER-CONNECTION"
static final String	QR_DELETE_USER_CONNECTION = "DELETE-USER-CONNECTION"
static final String	QR_SERVER_CONNECTION_CONTROL = "SERVER-CONNECTION-CONTROL"
static final String	QR_RELOAD_SERVER_CONNECTION = "RELOAD-SERVER-CONNECTION"
static final String	QR_READ_SERVER_CONNECTION = "READ-SERVER-CONNECTION"
static final String	QR_ADD_SERVER_CONNECTION = "ADD-SERVER-CONNECTION"
static final String	QR_MODIFY_SERVER_CONNECTION = "MODIFY-SERVER-CONNECTION"
static final String	QR_DELETE_SERVER_CONNECTION = "DELETE-SERVER-CONNECTION"
static final String	QR_FILESYSTEM_CONTROL = "FILESYSTEM-CONTROL"
static final String	QR_FILESYSTEM_READ = "FILESYSTEM-READ"
static final String	QR_FILESYSTEM_WRITE = "FILESYSTEM-WRITE"
static final String	QR_MAPPER_CONTROL = "MAPPER-CONTROL"
static final String	QR_RELOAD_MAPPER = "RELOAD-MAPPER"
static final String	QR_MODIFY_MAPPER = "MODIFY-MAPPER"
static final String	QR_VALUE_MAP_CONTROL = "VALUE-MAP-CONTROL"
static final String	QR_RELOAD_VALUE_MAP = "RELOAD-VALUE-MAP"
static final String	QR_MODIFY_VALUE_MAP = "MODIFY-VALUE-MAP"
static final String	QR_CREATE_SLA = "CREATE-SLA"
static final String	QR_DELETE_SLA = "DELETE-SLA"
static final String	QR_MODIFY_SLA = "MODIFY-SLA"
static final String	QR_SLA_CONTROL = "SLA-CONTROL"
static final String	QR_DEBUG_CONTROL = "DEBUG-CONTROL"
static final String	QR_REMOTE_DEPLOYMENT = "REMOTE-DEPLOYMENT"
static final String	QR_REMOTE_DELETE_INTERFACE = "REMOTE-DELETE-INTERFACE"
static final String	QR_REMOTE_RELEASE = "REMOTE-RELEASE"
static final String	QR_REMOTE_EXEC_ALL = "REMOTE-EXEC-ALL"
static final String	QR_KILL_PROCESS = "KILL-PROCESS"
static final String	QR_DATA_PROVIDER_CONTROL = "DATA-PROVIDER-CONTROL"
static final String	QR_DATA_PROVIDER_CREATE = "DATA-PROVIDER-CREATE"
static final String	QR_DATA_PROVIDER_READ = "DATA-PROVIDER-READ"
static final String	QR_DATA_PROVIDER_UPDATE = "DATA-PROVIDER-UPDATE"
static final String	QR_DATA_PROVIDER_DELETE = "DATA-PROVIDER-DELETE"
static final String	QR_TYPE_CACHE_CONTROL = "TYPE-CACHE-CONTROL"
static final String	QR_TYPE_CACHE_RELOAD = "TYPE-CACHE-RELOAD"
static final String	QR_TYPE_CACHE_CREATE = "TYPE-CACHE-CREATE"
static final String	QR_TYPE_CACHE_DELETE = "TYPE-CACHE-DELETE"
static final String	QR_SET_FSM_CONFIG = "SET-FSM-CONFIG"
	Finite State Machine System Permission: "SET-FSM-CONFIG". More...
static final String	QR_SET_PIPELINE_CONFIG = "SET-PIPELINE-CONFIG"
	Pipeline System Permission: "SET-PIPELINE-CONFIG". More...
static final String	QR_UPLOAD = "UPLOAD"
	#! Remote Command System Permission: "UPLOAD" More...
static final int	QE_CLASS_SYSTEM = 101
static final int	QE_CLASS_WORKFLOW = 102
static final int	QE_CLASS_SERVICE = 103
static final int	QE_CLASS_USER = 104
static final int	QE_CLASS_JOB = 105
static final int	QE_CLASS_ALERT = 106
static final int	QE_CLASS_GROUP = 107
static final int	QE_CLASS_CONNECTION = 108
static final int	QE_CLASS_PROCESS = 109
static final int	QE_CLASS_CLUSTER = 110
static final int	QE_CLASS_LOGGER = 111
static final int	QE_CLASS_CONFIG_ITEM = 112
static final Map< Integer, String >	QE_MAP_CLASS
static final int	QEC_SYSTEM_STARTUP = 1001
static final int	QEC_SYSTEM_SHUTDOWN = 1002
static final int	QEC_SYSTEM_ERROR = 1003
static final int	QEC_SYSTEM_HEALTH_CHANGED = 1004
static final int	QEC_SYSTEM_REMOTE_HEALTH_CHANGED = 1005
static final int	QEC_GROUP_STATUS_CHANGED = 1101
static final int	QEC_WORKFLOW_START = 2001
static final int	QEC_WORKFLOW_STOP = 2002
static final int	QEC_WORKFLOW_CACHE_RESET = 2003
static final int	QEC_WORKFLOW_DATA_SUBMITTED = 2004
static final int	QEC_WORKFLOW_DATA_ERROR = 2005
static final int	QEC_WORKFLOW_DATA_RELEASED = 2006
static final int	QEC_WORKFLOW_DATA_CACHED = 2007
static final int	QEC_WORKFLOW_INFO_CHANGED = 2008
static final int	QEC_WORKFLOW_STATUS_CHANGED = 2009
static final int	QEC_WORKFLOW_STEP_PERFORMANCE = 2010
static final int	QEC_WORKFLOW_PERFORMANCE = 2011
static final int	QEC_WORKFLOW_DATA_LOCKED = 2012
static final int	QEC_WORKFLOW_DATA_UNLOCKED = 2013
static final int	QEC_WORKFLOW_DATA_UPDATED = 2014
static final int	QEC_WORKFLOW_STATS_UPDATED = 2015
static final int	QEC_WORKFLOW_RECOVERED = 2016
static final int	QEC_WORKFLOW_UPDATED = 2017
static final int	QEC_WORKFLOW_STEP_DATA_UPDATED = 2018
static final int	QEC_SERVICE_START = 3001
static final int	QEC_SERVICE_STOP = 3002
static final int	QEC_SERVICE_ERROR = 3003
static final int	QEC_SERVICE_AUTOSTART_CHANGE = 3004
static final int	QEC_SERVICE_METHOD_PERFORMANCE = 3005
static final int	QEC_SERVICE_UPDATED = 3006
static final int	QEC_JOB_START = 4001
static final int	QEC_JOB_STOP = 4002
static final int	QEC_JOB_ERROR = 4003
static final int	QEC_JOB_INSTANCE_START = 4004
static final int	QEC_JOB_INSTANCE_STOP = 4005
static final int	QEC_JOB_RECOVERED = 4006
static final int	QEC_JOB_UPDATED = 4007
static final int	QEC_CONFIG_ITEM_CHANGED = 4100
static final int	QEC_ALERT_ONGOING_RAISED = 5006
static final int	QEC_ALERT_ONGOING_CLEARED = 5007
static final int	QEC_ALERT_TRANSIENT_RAISED = 5008
static final int	QEC_CONNECTION_UP = 5101
static final int	QEC_CONNECTION_DOWN = 5102
static final int	QEC_CONNECTION_ENABLED_CHANGE = 5103
static final int	QEC_CONNECTION_CREATED = 5104
static final int	QEC_CONNECTION_UPDATED = 5105
static final int	QEC_CONNECTION_DELETED = 5106
static final int	QEC_CONNECTIONS_RELOADED = 5107
static final int	QEC_CONNECTION_DEBUG_DATA_CHANGE = 5108
static final int	QEC_LOGGER_CREATED = 5200
static final int	QEC_LOGGER_UPDATED = 5201
static final int	QEC_LOGGER_DELETED = 5202
static final int	QEC_APPENDER_CREATED = 5203
static final int	QEC_APPENDER_DELETED = 5204
static final int	QEC_APPENDER_UPDATED = 5205
static final int	QEC_PROCESS_STARTED = 6001
static final int	QEC_PROCESS_STOPPED = 6002
static final int	QEC_PROCESS_START_ERROR = 6003
static final int	QEC_PROCESS_MEMORY_CHANGED = 6004
static final int	QEC_NODE_INFO = 7001
static final int	QEC_NODE_REMOVED = 7002
	Qorus Event Code: NODE_REMOVED. More...
static final int	QEC_USER_EVENT = 9001
static final Map< Integer, String >	QE_MAP_EVENT
static final int	QSE_OK = 0
static final int	QSE_NO_INSTANCE_KEY = 1
static final int	QSE_INVALID_DB_MAX_THREADS = 2
static final int	QSE_DATASOURCE = 3
static final int	QSE_LOG_ERROR = 4
static final int	QSE_RBAC_ERROR = 5
static final int	QSE_EVENT_ERROR = 6
static final int	QSE_SESSION_ERROR = 7
static final int	QSE_COMMAND_LINE_ERROR = 8
static final int	QSE_OPTION_ERROR = 9
static final int	QSE_VERSION_ONLY = 10
static final int	QSE_STARTUP_ERROR = 99
static final int	DefaultOrderPriority = 500
static final String	JS_Complete = "COMPLETE"
static final String	JS_InProgress = "IN-PROGRESS"
static final String	JS_Error = "ERROR"
static final String	JS_Crash = "CRASH"
static final String	SQL_JS_Complete = "C"
static final String	SQL_JS_InProgress = "I"
static final String	SQL_JS_Error = "E"
static final String	SQL_JS_Crash = "Z"
static final Map< String, String >	JSMap
static final Map< String, String >	SQLJSMap
static final int	AE_USER_EVENT = 1
static final int	AE_SYSTEM_STARTUP = 2
static final int	AE_SYSTEM_SHUTDOWN = 3
static final int	AE_SYSTEM_RECOVERY_START = 4
static final int	AE_SYSTEM_RECOVERY_COMPLETE = 5
static final int	AE_WORKFLOW_STATUS_CHANGE = 6
static final int	AE_WORKFLOW_START = 7
static final int	AE_WORKFLOW_STOP = 8
static final int	AE_SERVICE_START = 9
static final int	AE_SERVICE_STOP = 10
static final int	AE_JOB_START = 11
static final int	AE_JOB_STOP = 12
static final int	AE_JOB_INSTANCE_START = 13
static final int	AE_JOB_INSTANCE_STOP = 14
static final int	AE_API_CALL = 15
static final int	AE_JOB_RECOVERY = 16
static final int	AE_WORKFLOW_DATA_CREATED = 17
static final int	AE_ALERT_ONGOING_RAISED = 18
static final int	AE_ALERT_ONGOING_CLEARED = 19
static final int	AE_ALERT_TRANSIENT_RAISED = 20
static final int	AE_SOURCE_FILE_LOADED = 21
static final int	AE_GROUP_STATUS_CHANGED = 22
static final String	AES_USER_EVENT = "USER-EVENT"
static final String	AES_SYSTEM_STARTUP = "SYSTEM-STARTUP"
static final String	AES_SYSTEM_SHUTDOWN = "SYSTEM-SHUTDOWN"
static final String	AES_SYSTEM_RECOVERY_START = "SYSTEM-RECOVERY-START"
static final String	AES_SYSTEM_RECOVERY_COMPLETE = "SYSTEM-RECOVERY-COMPLETE"
static final String	AES_WORKFLOW_STATUS_CHANGE = "WORKFLOW-STATUS-CHANGE"
static final String	AES_WORKFLOW_START = "WORKFLOW-START"
static final String	AES_WORKFLOW_STOP = "WORKFLOW-STOP"
static final String	AES_SERVICE_START = "SERVICE-START"
static final String	AES_SERVICE_STOP = "SERVICE-STOP"
static final String	AES_JOB_START = "JOB-START"
static final String	AES_JOB_STOP = "JOB-STOP"
static final String	AES_JOB_INSTANCE_START = "JOB-INSTANCE-STOP"
static final String	AES_JOB_INSTANCE_STOP = "JOB-INSTANCE-START"
static final String	AES_API_CALL = "API-CALL"
static final String	AES_JOB_RECOVERY = "JOB-RECOVERY"
static final String	AES_WORKFLOW_DATA_CREATED = "WORKFLOW-DATA-CREATED"
static final String	AES_ALERT_ONGOING_RAISED = "ALERT-ONGOING-RAISED"
static final String	AES_ALERT_ONGOING_CLEARED = "ALERT-ONGOING-CLEARED"
static final String	AES_ALERT_TRANSIENT_RAISED = "ALERT-TRANSIENT-RAISED"
static final String	AES_SOURCE_FILE_LOADED = "SOURCE-FILE-LOADED"
static final String	AES_GROUP_STATUS_CHANGED = "GROUP-STATUS-CHANGED"
static final Map< Integer, String >	AuditEventMap
static final Map< String, Integer >	AuditEventCodeMap
static final String	AO_SYSTEM = "system"
static final String	AO_WORKFLOWS = "workflows"
static final String	AO_WORKFLOW_DATA = "workflow-data"
static final String	AO_JOBS = "jobs"
static final String	AO_JOB_DATA = "job-data"
static final String	AO_SERVICES = "services"
static final String	AO_API = "api"
static final String	AO_USER_EVENTS = "user-events"
static final String	AO_OLOAD_EVENTS = "oload"
static final String	AO_ALERT_EVENTS = "alerts"
static final String	AO_GROUP_EVENTS = "groups"
static final int	AOC_SYSTEM = (1 << 0)
static final int	AOC_WORKFLOWS = (1 << 1)
static final int	AOC_WORKFLOW_DATA = (1 << 2)
static final int	AOC_JOBS = (1 << 3)
static final int	AOC_JOB_DATA = (1 << 4)
static final int	AOC_SERVICES = (1 << 5)
static final int	AOC_API = (1 << 6)
static final int	AOC_USER_EVENTS = (1 << 7)
static final int	AOC_OLOAD_EVENTS = (1 << 8)
static final int	AOC_ALERT_EVENTS = (1 << 9)
static final int	AOC_GROUP_EVENTS = (1 << 10)
static final int	AuditMask = (AOC_SYSTEM|AOC_WORKFLOWS|AOC_WORKFLOW_DATA|AOC_JOBS|AOC_JOB_DATA|AOC_SERVICES|AOC_API|AOC_USER_EVENTS|AOC_OLOAD_EVENTS|AOC_ALERT_EVENTS|AOC_GROUP_EVENTS)
static final Map< String, Integer >	AuditOptionMap
static final Map< Integer, String >	AuditCodeMap
Private Member Methods inherited from com.qoretechnologies.qorus.workflow.QorusStepBase
HashMap< String, ConfigItem >	getConfigItemsImpl ()

Detailed Description

The Java interface class for workflow synchronization event array steps

Workflow synchronization event steps allow many workflow orders to synchronize their processing based on a single event.

Event steps may not have validation logic.

Example

// name: MyEventArrayStepClass
// version: 1.0
// desc: my event array step class
// lang: java8
import com.qoretechnologies.qorus.OMQ;
import com.qoretechnologies.qorus.UserApi;
import com.qoretechnologies.qorus.workflow.WorkflowApi;
import com.qoretechnologies.qorus.workflow.QorusEventArrayStep;
 
public class MyEventArrayStepClass implements QorusEventArrayStep {
    public Object[] array() throws Throwable {
        // .. array logic
    }
 
    public void primary(Object array_arg) throws Throwable {
        // .. primary step logic; must call one of:
        // * bindEvent()
        // * bindEventUnposted()
        // * skipEvent()
    }
}
// END

Note

Qorus step constructors do not take any arguments; see Step Constructors and Static Initialization for information about constructors and static class initialization.

See also

Workflow Synchronization Event Steps Array Step

Member Function Documentation

array()

abstract Object [] com.qoretechnologies.qorus.workflow.QorusEventArrayStep.array ( ) throws Throwable

abstract

The array method returns the list of elements for the step

Returns

The return value of the array function will determine how many times the step will execute, and on what data; null or a zero-length array means to skip the step entirely. Each element in this array indicates an array step element; each element will be passed as the argument to primary() and validation()

Exceptions

Throwable

any exceptions are converted to Qore exceptions and processed as workflow errors

primary()

abstract void com.qoretechnologies.qorus.workflow.QorusEventArrayStep.primary ( Object  array_arg ) throws Throwable

abstract

The primary step logic for the event step

This code must call either bindEvent(), bindEventUnposted(), or skipEvent() or an error will be raised.

Parameters

array_arg

the array element for this step index as returned by the array method

Exceptions

Throwable

any exceptions are converted to Qore exceptions and processed as workflow errors

---

The documentation for this class was generated from the following file:

• /builds/qorus/qorus/java/com/qoretechnologies/qorus/workflow/QorusEventArrayStep.java