Qorus Integration Engine® Enterprise Edition 7.1.0_prod
Loading...
Searching...
No Matches
OMQ::UserApi::Workflow::QorusEventStepBase Class Reference

The Qore base interface class for event steps. More...

Inheritance diagram for OMQ::UserApi::Workflow::QorusEventStepBase:
[legend]
Collaboration diagram for OMQ::UserApi::Workflow::QorusEventStepBase:
[legend]

Static Public Member Methods

 bindEvent (string eventkey)
 binds a workflow synchronization event based on the event key to a workflow synchronization event step (type OMQ::ExecEvent)
 
 bindEventUnposted (string eventkey)
 binds a workflow synchronization event based on the event key to a workflow synchronization event step (type OMQ::ExecEvent) only if the event has not yet been posted; if the event has already been posted, then an ALREADY-POSTED exception is raised
 
 skipEvent ()
 skips a workflow synchronization event step
 
- Static Public Member Methods inherited from OMQ::UserApi::Workflow::QorusStepBase
static updateStepData (hash< auto > new_data)
 Updates the values of one or more keys in the workflow order data instance’s dynamic step data hash.
 
static deleteStepDataKey (softlist< softstring > keylist)
 Deletes one or more keys from the workflow order data instance’s dynamic step data hash.
 
static auto getStepData ()
 Retrieves the values of one or more keys from the workflow order data instance’s dynamic step data hash.
 
static auto getStepDataArgs (*softlist< softstring > keylist)
 Retrieves the values of one or more keys from the workflow order data instance’s dynamic step data hash.
 
- Static Public Member Methods inherited from OMQ::UserApi::Workflow::WorkflowApi
static string generateUniqueKey ()
 returns a unique async key for the order for use with QorusAsyncStepBase::submitAsyncKey()
 
static stepError (string err, auto info)
 Raises an error against the current step without affecting the flow of processing.
 
static stepError (string err, auto info, date retry_delay)
 Raises an error against the current step without affecting the flow of processing.
 
static stepError (string err, auto info, int retry_delay)
 Raises an error against the current step without affecting the flow of processing.
 
static stepWarning (string err, auto info)
 Raises a warning against the step.
 
static stepWarning (string err, string fmt,...)
 Raises a warning against the step.
 
static setRetryDelay (date delay)
 Sets the value of the retry delay for a step error or an asynchronous step.
 
static setRetryDelay (int secs)
 Sets the value of the retry delay for a step error or an asynchronous step.
 
static *hash< auto > getErrorInfo (string err)
 Returns the hash data associated with the error code passed as an argument.
 
static updateDynamicData (hash< auto > hash)
 Updates the values of one or more keys in the workflow order’s dynamic data hash.
 
static deleteDynamicDataKey (softlist< auto > list)
 Deletes one or more keys from the workflow order data instance’s dynamic data hash.
 
static auto getDynamicData (...)
 Retrieves the values of one or more keys from the workflow order data instance’s dynamic data hash.
 
static auto getDynamicDataArgs (*softlist< auto > keylist)
 Retrieves the values of one or more keys from the workflow order data instance’s dynamic data hash.
 
static auto getStaticData (...)
 Retrieves the values of one or more keys from the workflow order data instance’s static data hash.
 
static auto getStaticDataArgs (*softlist< auto > keylist)
 Retrieves the values of one or more keys from the workflow order data instance’s static data hash.
 
static updateTempData (hash< auto > hash)
 Updates the values of one or more keys in the workflow order data instance’s temporary data hash.
 
static auto getTempData (...)
 Retrieves the values of one or more keys from the workflow order data instance’s temporary data hash.
 
static auto getTempDataArgs (*softlist< auto > keylist)
 Retrieves the values of one or more keys from the workflow order data instance’s temporary data hash.
 
static deleteTempDataKey (softlist< auto > keylist)
 Deletes one or more keys from the workflow order data instance’s temporary data hash.
 
static updateSensitiveData (string skey, string svalue, hash< auto > hash, *softlist aliases, *hash< auto > meta)
 Updates or creates the values of one or more keys in the workflow order's sensitive data hash for the given sensitive data key and value.
 
static updateSensitiveDataFromAlias (string alias, hash< auto > hash, *hash< auto > meta)
 Updates or creates the values of one or more keys in the workflow order's sensitive data hash for the given sensitive data alias.
 
static auto getSensitiveMetadata (string skey, string svalue)
 Returns the sensitive metadata hash for the given sensitive data key and value if present, otherwise returns an empty hash.
 
static hash getSensitiveMetadataFromAlias (string alias)
 returns a hash with the corresponding sensitive data key and sensitive data value as well as the value of the sensitive metadata hash for the given sensitive data alias corresponding to a sensitive data key and value
 
static auto getSensitiveData (string skey, string svalue,...)
 Returns the sensitive data for the given sensitive data key and value.
 
static auto getSensitiveDataArgs (string skey, string svalue, *list< auto > keylist)
 Returns the sensitive data for the given sensitive data key and value.
 
static hash< auto > getSensitiveDataFromAlias (string alias,...)
 returns a hash with the corresponding sensitive data key and sensitive data value as well as the value of one or more keys in the workflow sensitive data hash for the given sensitive data alias corresponding to a sensitive data key and value
 
static hash< auto > getSensitiveDataFromAliasArgs (string alias, *list< auto > keylist)
 returns a hash with the corresponding sensitive data key and sensitive data value as well as the value of one or more keys in the workflow sensitive data hash for the given sensitive data alias corresponding to a sensitive data key and value
 
static hash< auto > getSensitiveDataAliases ()
 returns a hash of all sensitive data aliases for the current order or an empty hash if there are none
 
static bool deleteSensitiveData (string skey, string svalue)
 Deletes the sensitive data hash for the given sensitive data key and value; changes have already been committed to the database when this method returns.
 
static bool deleteSensitiveDataKey (string skey, string svalue, softlist< auto > list)
 Deletes one or more keys from the workflow order data instance’s sensitive data hash for the given sensitive data key and value; changes have already been committed to the database when this method returns.
 
static hash getSensitiveDataKeyValues ()
 Returns a hash of sensitive data keys and values saved against the order; the sensitive data hashes themselves are not returned, just the information used to index sensitive data against the order.
 
static updateInstanceData (hash< auto > hash)
 Updates the values of one or more keys in the workflow execution instance’s instance data hash.
 
static deleteInstanceDataKey (softlist< auto > list)
 Deletes a single key or a list of keys from the workflow execution instance’s instance data hash.
 
static auto getInstanceData (...)
 Retrieves the values of one or more keys from the workflow execution instance’s instance data hash.
 
static auto getInstanceDataArgs (*list< auto > keylist)
 Retrieves the values of one or more keys from the workflow execution instance’s instance data hash.
 
static auto getWorkflowInstanceData (string field)
 Retrieves the value of a single key (system-defined property) from the workflow execution instance object itself.
 
static hash< auto > getWorkflowInstanceData (...)
 Retrieves the values of multiple keys (system-defined properties) from the workflow execution instance object itself.
 
static hash< auto > getWorkflowInstanceDataArgs (*list< auto > keylist)
 Retrieves the values of one or more keys (system-defined properties) from the workflow execution instance object itself as a hash.
 
static setOrderKeys (hash< auto > h, bool truncate=False)
 This method sets user-defined order keys against an order, so that the workflow order data instance can be quickly searched and retrieved using the key value.
 
static setOrderKey (string key, softlist< softstring > value, bool truncate=False)
 This method sets the values for a sinle user-defined order key against an order, so that the workflow order data instance can be quickly searched and retrieved using the key value.
 
static appendOrderKeys (hash< auto > h, bool truncate=False)
 This method appends user-defined order key values to a workflow order key, so that the workflow order data instance can be quickly searched and retrieved using the key value.
 
static appendOrderKeys (string key, softlist< softstring > value, bool truncate=False)
 This method appends user-defined order key values to a workflow order key, so that the workflow order data instance can be quickly searched and retrieved using the key value.
 
static auto getOrderKeys (...)
 This method retrieves the user-defined order key information saved against the workflow order data instance.
 
static auto getOrderKeysArgs (*softlist< auto > keylist)
 This method retrieves the user-defined order key information saved against the workflow order data instance.
 
static bool stepExecuted (string stepname)
 This method returns True if the step passed has been executed and has status OMQ::StatComplete ("C")
 
static *string getStepStatus (string stepname)
 Returns the current status of the given step for the current workflow order instance.
 
static *hash< auto > getStepInfo ()
 This method will return a hash of step information for the current step.
 
static hash< auto > getWorkflowMetadata ()
 returns workflow metadata for the currently running workflow as a hash
 
static setBlocked ()
 set the current workflow order status to OMQ::StatBlocked, can only be called from the attach function
 
static list getOrderNotes (*int count)
 Get Order Instance Notes.
 
static addOrderNote (string notestr)
 Add new note as described in Order Instance Notes.
 
static setCustomStatus (string stat)
 Sets a user-defined custom status for the current step.
 
static rescheduleOrder (date scheduled)
 reschedules the current workflow order instance for later processing
 
static reprioritizeOrder (int prio)
 changes the order priority for the current workflow order instance
 
static leaveParentFeedback (string key, auto value)
 leaves feedback for a parent workflow
 
static auto getChildFeedback (string key)
 gets feedback from a child workflow order with the given key
 
static *hash< auto > getChildFeedback ()
 gets all feedback from all child workflow orders as a hash
 
static setOption (hash< auto > hash)
 Changes option values on a workflow.
 
static setOption (string option, auto value)
 Changes a single option value on a workflow.
 
static auto getOption (...)
 Returns the value of the named workflow option(s)
 
static auto getOptionArgs (*softlist< string > args)
 Returns the value of the named workflow option or options.
 
static *softint parentWfiid ()
 Returns the parent workflow order data instance ID from a subworkflow or NOTHING if the current workflow order is not a subworkflow and therefore has no parent.
 
static *softint getWfiid ()
 returns the current workflow_instanceid as an integer; returns NOTHING if not called in a workflow order context (ex: onetimeinit function, etc)
 
static int sleep (softint arg)
 puts the current thread to sleep for a certain number of seconds
 
static int usleep (softint arg)
 puts the current thread to sleep for a certain number of microseconds
 
static int usleep (date arg)
 puts the current thread to sleep for a certain number of microseconds
 
static auto getConfigItemValue (string item, *hash< auto > local_context, bool expand_complex_values=True)
 returns the value of the given step configuration item
 
static hash< auto > getConfigItemHash (*hash< auto > local_context)
 returns a hash of all configuration items for the current step
 
- Static Public Member Methods inherited from OMQ::UserApi::UserApi
static *hash< auto > getUserServiceInfo (string name)
 returns information about the given user service (if it's currently loaded)
 
static SqlUtil::AbstractTable getSqlTable (string datasource, string table_name, bool register_dependency=True)
 get a cached table object (suitable for DML) if present, otherwise it creates one from scratch
 
static SqlUtil::AbstractTable getSqlTable (AbstractDatasource datasource, string table_name, bool register_dependency=True)
 get a cached table object (suitable for DML) if present, otherwise it creates one from scratch
 
static hash< auto > getSqlCacheInfo ()
 get information about cached object
 
static clearSqlTableCache (string datasource, *string table_name)
 clears all objects for given datasource from the cache (for example, if database objects have been updated in the dataserver)
 
static clearSqlTableCache (AbstractDatasource datasource, *string table_name)
 clears cached objects for given datasource (for example, if database objects have been updated in the dataserver)
 
static auto getValueMap (string mapname, string key)
 Gets a lookup value from the value map by a key; the value map must be registered to the current interface.
 
static list< auto > getValueMaps ()
 Gets all value maps valid for the current interface.
 
static bool postSlaEventSuccess (string sla, number value)
 posts a successful SLA event for SLA monitoring and performance tracking
 
static bool postSlaEventError (string sla, number value, string err, string desc)
 posts an unsuccessful SLA event for SLA monitoring and performance tracking
 
static flushSlaEvents ()
 flushes all pending SLA events to disk and returns after the data has been committed
 
static *hash< auto > getSystemServiceInfo (string name)
 returns information about the given system service (if it's currently loaded)
 
static *hash< auto > getServiceInfo (string type, string name)
 returns information about the given service (if it's currently loaded)
 
static list getRunningWorkflowList (*string name, *string ver)
 returns a list of hashes giving information about the currently-running workflow execution instances
 
static hash getRunningWorkflowInfo (softint id)
 returns a hash of the workflow execution instance info if the ID is valid or an empty hash if not
 
static softint createOrder (string name, *string version, hash< auto > params, string status=StatReady)
 creates a workflow order data instance in the database
 
static softint createOrder (int wfid, hash< auto > params, string status=StatReady)
 creates a workflow order data instance in the database
 
static softint createRemoteOrder (string remote, string name, *string version, hash< auto > params, string status=StatReady, bool register_dependency=True)
 creates a workflow order data instance in a remote Qorus instance
 
static softint createRemoteOrder (string remote, int wfid, hash< auto > params, string status=StatReady, bool register_dependency=True)
 creates a workflow order data instance in a remote Qorus instance
 
static hash< auto > execSynchronousWorkflow (string name, *string version, hash< auto > sdata, *hash< auto > opts, *hash< auto > ddata, softint priority=DefaultOrderPriority, *hash< auto > orderkeys, *softstring external_order_instanceid, *softint parent_workflow_instanceid)
 executes a workflow order synchronously and returns the final status and order ID in a hash
 
static hash< auto > execSynchronousWorkflow (int wfid, hash< auto > sdata, *hash< auto > opts, *hash< auto > ddata, softint priority=DefaultOrderPriority, *hash< auto > orderkeys, *softstring external_order_instanceid, *softint parent_workflow_instanceid)
 executes a workflow order synchronously and returns the final status and order ID in a hash
 
static hash< auto > execSynchronousWorkflowAsync (string name, *string version, hash< auto > sdata, *hash< auto > opts, *hash< auto > ddata, softint priority=DefaultOrderPriority, *hash< auto > orderkeys, *softstring external_order_instanceid, *softint parent_workflow_instanceid)
 executes a workflow order synchronously in the background and returns immediately
 
static hash< auto > execSynchronousWorkflowAsync (int wfid, hash< auto > sdata, *hash< auto > opts, *hash< auto > ddata, softint priority=DefaultOrderPriority, *hash< auto > orderkeys, *softstring external_order_instanceid, *softint parent_workflow_instanceid)
 executes a workflow order synchronously in the background and returns immediately
 
static int postUserEvent (string severity, auto info)
 posts an application event of class OMQ::QE_CLASS_USER
 
static hash runtimeProperties ()
 returns Qorus runtime properties as a hash
 
static auto callNetworkApiArgsWithAuthentication (string user, string pass, string call, softlist< auto > args)
 calls a system RPC API with authentication information (username and password)
 
static auto callNetworkApiArgs (string call, *softlist< auto > args)
 calls a system RPC API and returns the respose
 
static auto callNetworkApi (string call,...)
 calls a system RPC API and returns the result; the API is called with system permissions (no restrictions)
 
static auto callRestApi (string method, string path, *hash< auto > body_args)
 calls a system REST API method and returns the result
 
static auto callRestApiWithAuthentication (string user, string pass, string method, string path, *hash< auto > body_args)
 calls a system REST API method with authentication information and returns the result
 

Additional Inherited Members

- Public Member Methods inherited from OMQ::UserApi::Workflow::QorusStepBase
*hash< auto > getDefaultStepData ()
 Returns the default dynamic step data for the step when the step is first run.
 
*hash< auto > getStepMetadata ()
 Returns step user metadata for the step when the step is loaded by oload.
 
- Public Member Methods inherited from OMQ::UserApi::QorusConfigurationItemProvider
final *hash< string, hash< ConfigItemInfo > > getConfigItems ()
 Method to return local configuration items.
 
*hash< string, hash< ConfigItemInfo > > getConfigItemsImpl ()
 Method to return local configuration items; this method should be overridden by child classes to provide item configuration.
 
- Static Private Member Methods inherited from OMQ::UserApi::UserApi
static QorusProgram DynamicLogic (True, False, CommonParseOptions|PO_NO_INHERIT_USER_CLASSES|PO_NO_INHERIT_USER_FUNC_VARIANTS|PO_NO_INHERIT_GLOBAL_VARS|PO_NO_INHERIT_USER_CONSTANTS|PO_NO_INHERIT_USER_HASHDECLS|PO_NEW_STYLE|PO_STRICT_ARGS|PO_REQUIRE_TYPES, QorusServerDefines, NOTHING, NOTHING,())
 Program for dynamic logic.
 
- Private Attributes inherited from OMQ::UserApi::UserApi
const DataProviderRootValues
 data provider root path values
 
const DataTypeRootValues
 data type root path values
 
const DataProviderPathTypeValues
 data type path provider type values
 

Detailed Description

The Qore base interface class for event steps.

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

Member Function Documentation

◆ bindEvent()

OMQ::UserApi::Workflow::QorusEventStepBase::bindEvent ( string  eventkey)
static

binds a workflow synchronization event based on the event key to a workflow synchronization event step (type OMQ::ExecEvent)

If this method is called twice for the same step, or if called after skipEvent(), then an exception is raised. The event type is defined when the step is defined in the workflow definition (see Workflow Synchronization Step Event Type); this information does not need to be supplied here; only the event key, and the event will be automatically created (if it does not exist) or found in the queue as defined by its event type.

Parameters
eventkeythe event key to bind the step to; if the event key does not already exist, then it is created in the table WORKFLOW_EVENTS and automatically tagged with its event type. A record for this step is also created in STEP_INSTANCE_EVENTS
Exceptions
WORKFLOW-EVENT-ERRORinvalid method call (multiple call, etc)
See also
Note
either bindEvent(), bindEventUnposted(), or skipEvent() must be called in a workflow synchronization event step

◆ bindEventUnposted()

OMQ::UserApi::Workflow::QorusEventStepBase::bindEventUnposted ( string  eventkey)
static

binds a workflow synchronization event based on the event key to a workflow synchronization event step (type OMQ::ExecEvent) only if the event has not yet been posted; if the event has already been posted, then an ALREADY-POSTED exception is raised

If this method is called twice for the same step, or if called after skipEvent(), then an exception is raised. The event type is defined when the step is defined in the workflow definition (see Workflow Synchronization Step Event Type); this information does not need to be supplied here; only the event key, and the event will be automatically created (if it does not exist) or found in the queue as defined by its event type.

Parameters
eventkeythe event key to bind the step to; if the event key does not already exist, then it is created in the table WORKFLOW_EVENTS and automatically tagged with its event type. A record for this step is also created in STEP_INSTANCE_EVENTS
Exceptions
ALREADY-POSTEDthe given event has already been posted
WORKFLOW-EVENT-ERRORinvalid method call (multiple call, etc)
See also
Note
either bindEvent(), bindEventUnposted(), or skipEvent() must be called in a workflow synchronization event step

◆ skipEvent()

OMQ::UserApi::Workflow::QorusEventStepBase::skipEvent ( )
static

skips a workflow synchronization event step

If this method is called from any other step type, or if called after bindEvent(), then an exception is raised. If called twice for the same step a message is logged, but no exception is raised.

Exceptions
WORKFLOW-EVENT-ERRORinvalid method call (multiple call, etc)
See also
Note
either bindEvent(), bindEventUnposted(), or skipEvent() must be called in a workflow synchronization event step

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