queue
Simple message queueing system that enables events to be added to a queue which can then later be executed by a trigger.
Triggers
Queue Trigger
Checks a given queue for new events that are ready to be executed.
Input
| Name | Description | Type | Required | Syntax |
|---|---|---|---|---|
| _id | input | False | False | |
| Name | Display name for the trigger object. | input | False | False |
| Enabled | Enable / Disable this trigger object. | checkbox | False | False |
| Variables | Variables to define when triggering an event. | var | False | True |
| Schedule | How often to run the flow. e.g. 10s - every 10 seconds, 1-5h - random start between 1 and 5 hours, */5 * * * * - every 5 minutes. | input | False | False |
| Max Duration | The number of seconds that a flow can be running before it is automatically killed and/or considered dead and restarted. | input | False | False |
| Limit | The maximum number of events to execute per trigger check. | input | False | False |
| Comment | User defined comments. | input | False | False |
| Concurrency | How many events to run through the flow at once. | input | False | False |
| Take Snapshots | When checked snapshots of every execution will be saved. | checkbox | False | False |
| Max Retries | The number of attempts to automatically reattempt a failing trigger. | input | False | False |
| Retry Delay | Delay time between failure and automatically reattempting a failing trigger. | input | False | False |
| On Trigger Crash | Trigger ID to call when a trigger crashes. | input | False | False |
| On Trigger Killed | Trigger ID to call when a trigger overruns its max duration and is killed. | input | False | False |
| Fail Trigger On Action Crash | When true the entire flow will crash if a single action crashes. | group-checkbox | False | False |
| On Action Crash | Trigger ID to call when an action crashes and Fail Trigger On Action Crash is checked. | input | False | False |
Output
| Name | Description | Type | always_present | values |
|---|---|---|---|---|
| event | An event as defined within the queue. | json | True | {} |
Actions
Queue Add Event
Adds a new event to a queue.
Input
| Name | Description | Type | Required | Syntax |
|---|---|---|---|---|
| _id | input | False | False | |
| Name | Display name for the action object. | input | False | False |
| Enabled | Enable / Disable this action object. | checkbox | False | False |
| Logic | Logic that when defined must be evaluated as true for the action object to return True otherwise False will be returned. | input | False | False |
| Variables | Variables to define when triggering an event. | var | False | True |
| Queue TriggerID | The ID of the queue trigger object that will be used to execute events. | input | False | True |
| Use Existing Event | When checked the current event value will be used when adding the event to the queue. | group-checkbox | False | False |
| Event String | Used to define an event using replacement syntax. This only takes affect if 'Use Existing Event' is unchecked. | input | False | True |
| Event Data | Used to build a custom event. This only take affect if 'Use Existing Event' is unchecked and no value is provided within 'Event String' | json-input | False | True |
| Auto Clear | When checked the event will automatically be removed from the queue as soon as it is executed by the queue trigger no matter the result. | checkbox | False | False |
| Delay | Define a delay in seconds that must pass before the queue trigger will execute this event. | input | False | False |
| Comment | User defined comments. | input | False | False |
Output
| Name | Description | Type | always_present | values |
|---|---|---|---|---|
| result | Returns True when successful. | boolean | True | {"True": {"description": "Successful."}, "False": {"description": "Failure."}} |
| rc | Returns the exit code for the action. | number | True | {"0": {"description": "Successful."}, "1": {"description": "You must define a queue triggerID."}, "500": {"description": "No event data was provided so it cannot be added to the queue."}} |
| queueEventID | Returns a unique eventID that can be used to reference the event added to the queue. | string | False | {} |
Queue Event Clear
Manually remove an event from the queue.
Input
| Name | Description | Type | Required | Syntax |
|---|---|---|---|---|
| _id | input | False | False | |
| Name | Display name for the action object. | input | False | False |
| Enabled | Enable / Disable this action object. | checkbox | False | False |
| Logic | Logic that when defined must be evaluated as true for the action object to return True otherwise False will be returned. | input | False | False |
| Variables | Variables to define when triggering an event. | var | False | True |
| Queue EventID | The ID of the event added within the queue. | input | False | True |
| Comment | User defined comments. | input | False | False |
Output
| Name | Description | Type | always_present | values |
|---|---|---|---|---|
| result | Returns True when successful. | boolean | True | {"True": {"description": "Successful."}, "False": {"description": "Failure."}} |
| rc | Returns the exit code for the action. | number | True | {"0": {"description": "Successful event removed from queue."}, "500": {"description": "No queue object found by this eventID."}} |