Home Applications EventsQueue

EventsQueue

by 
This application is not supported by InterSystems Corporation. Please be notified that you use it at your own risk.
0
0 reviews
0
Awards
135
Views
0
IPM installs
0
0
Details
Releases
Reviews
Issues
Sample of making queue for processing tasks based on InsterSystems Caché %SYSTEM.Event

What's new in this version

Initial Release

EventsQueue

Sample of making queue for processing tasks based on InsterSystems Caché %SYSTEM.Event

Example:

/// Starts the queue for processing reports
/// pAgents - number of agents to process the queue, default value = 2
/// pProcess - process tasks that were made before queue has started. 1 - process, 0 - ignore.
ClassMethod StartQueue(pAgents As %Integer = 2, pProcess As %Integer = 0) As %Status
{
	set st = $$$OK
	try {
		$$$TOE(st, ##class(Manager).Start(..#EVENTRESOURCE, 2, $classname(), "ProcessTask"))
		if (pProcess = 1) {
			set id = 0
			while (id < 10) {
				set id = id + 1
				set sent = $system.Event.Signal(..#EVENTRESOURCE, id)
    				if ('sent) $$$ThrowStatus($$$ERROR("Unable to start task processing for id = "_id))
			}
		}
	} catch ex {
		set st = ex.AsStatus()
	}
	quit st
}

/// Stops the queue
ClassMethod StopQueue() As %Status
{
set st = $$$OK
try {
$$$TOE(st, ##class(Manager).Stop(..#EVENTRESOURCE))
} catch ex {
set st = ex.AsStatus()
}
quit st
}

Version
1.21.301 Jun, 2018
Category
Technology Example
Works with
Caché
First published
01 Jun, 2018
Last checked by moderator
02 Jul, 2024Doesn't work