Index: TECH/PubSub/impl/EventQueue.cls.xml
===================================================================
diff -u
--- TECH/PubSub/impl/EventQueue.cls.xml	(revision 0)
+++ TECH/PubSub/impl/EventQueue.cls.xml	(revision 3451)
@@ -0,0 +1,63 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<Export generator="Cache" version="24">
+<Class name="TECH.PubSub.impl.EventQueue">
+<Super>TECH.RegisteredObject</Super>
+
+<Property name="EventRaiser">
+<Type>TECH.PubSub.EventRaiser</Type>
+<Private>1</Private>
+</Property>
+
+<Property name="EventList">
+<Type>%ListOfObjects</Type>
+<Private>1</Private>
+</Property>
+
+<Method name="%OnNew">
+<FormalSpec>EventRaiser:TECH.PubSub.EventRaiser</FormalSpec>
+<Private>1</Private>
+<ProcedureBlock>1</ProcedureBlock>
+<ReturnType>%Status</ReturnType>
+<ServerOnly>1</ServerOnly>
+<Implementation><![CDATA[
+	Set ..EventRaiser = EventRaiser
+	Set ..EventList = ##class(%ListOfObjects).%New()
+	 
+	Quit $$$OK
+]]></Implementation>
+</Method>
+
+<Method name="ClearEventList">
+<Implementation><![CDATA[	Do ..EventList.Clear()
+]]></Implementation>
+</Method>
+
+<Method name="AddEvent">
+<FormalSpec>Event:TECH.PubSub.Event</FormalSpec>
+<Implementation><![CDATA[	Do ..EventList.Add(Event)
+]]></Implementation>
+</Method>
+
+<Method name="ExecuteEventsAsync">
+<Implementation><![CDATA[
+	#dim EventListIterator As TECH.ListIterator = ##class(TECH.ListIterator).%New(..EventList)
+	While EventListIterator.HasNext() {
+		Do ..EventRaiser.RaiseEventAsync(EventListIterator.Next())
+	}
+	Do ..EventList.Clear()
+]]></Implementation>
+</Method>
+
+<Method name="ExecuteEventsSync">
+<Implementation><![CDATA[
+	#dim EventListIterator As TECH.ListIterator = ##class(TECH.ListIterator).%New(..EventList)
+	While EventListIterator.HasNext() {
+		Do ..EventRaiser.RaiseEventSync(EventListIterator.Next())
+	}
+	Do ..EventList.Clear()
+]]></Implementation>
+</Method>
+</Class>
+
+
+</Export>