Index: TECH/PubSub/impl/WachtendEventStatus.cls.xml
===================================================================
diff -u
--- TECH/PubSub/impl/WachtendEventStatus.cls.xml	(revision 0)
+++ TECH/PubSub/impl/WachtendEventStatus.cls.xml	(revision 17777)
@@ -0,0 +1,50 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<Export generator="Cache" version="9">
+<Class name="TECH.PubSub.impl.WachtendEventStatus">
+<ClassType>persistent</ClassType>
+<ProcedureBlock>1</ProcedureBlock>
+<Super>%Persistent</Super>
+<ClassDefinitionError>0</ClassDefinitionError>
+
+<Index name="MainIndex">
+<IdKey>1</IdKey>
+<Properties>EventID</Properties>
+</Index>
+
+<Property name="EventID">
+<Type>%String</Type>
+</Property>
+
+<Property name="Status">
+<Type>%String</Type>
+</Property>
+
+<Method name="%OnNew">
+<FormalSpec>EventID:%String=""</FormalSpec>
+<Private>1</Private>
+<ProcedureBlock>1</ProcedureBlock>
+<ReturnType>%Status</ReturnType>
+<Implementation><![CDATA[	set ..EventID = EventID
+]]></Implementation>
+</Method>
+
+<Storage name="Default">
+<Type>%Library.CacheStorage</Type>
+<DataLocation>^TECH.PubSub583.WachtendEven7B4D</DataLocation>
+<DefaultData>WachtendEventStatusDefaultData</DefaultData>
+<IdLocation>^TECH.PubSub583.WachtendEven7B4D</IdLocation>
+<IndexLocation>^TECH.PubSub583.WachtendEven7B4I</IndexLocation>
+<StreamLocation>^TECH.PubSub583.WachtendEven7B4S</StreamLocation>
+<Data name="WachtendEventStatusDefaultData">
+<Structure>listnode</Structure>
+<Subscript/>
+<Value name="1">
+<Value>%%CLASSNAME</Value>
+</Value>
+<Value name="2">
+<Value>Status</Value>
+</Value>
+</Data>
+</Storage>
+</Class>
+</Export>
Index: TECH/PubSub/impl/WachtendEventAanmaken.cls.xml
===================================================================
diff -u -r4227 -r17777
--- TECH/PubSub/impl/WachtendEventAanmaken.cls.xml	(.../WachtendEventAanmaken.cls.xml)	(revision 4227)
+++ TECH/PubSub/impl/WachtendEventAanmaken.cls.xml	(.../WachtendEventAanmaken.cls.xml)	(revision 17777)
@@ -1,6 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <Export generator="Cache" version="9">
 <Class name="TECH.PubSub.impl.WachtendEventAanmaken">
+<IncludeCode>vhLib.Macro</IncludeCode>
 <ProcedureBlock>1</ProcedureBlock>
 <Super>TECH.PubSub.EventRaiser</Super>
 <ClassDefinitionError>0</ClassDefinitionError>
@@ -11,12 +12,74 @@
 <Implementation><![CDATA[
 	Set WachtendEvent = ##class(TECH.PubSub.WachtendEvent).%New(Event)
 	Set Status = WachtendEvent.%Save()
-	If ($$$ISERR(Status))
-	{
+	If ($$$ISERR(Status)) {
 		Set Logger = ##class(TECH.PubSub.impl.PubSubLogger).%New()
 		Do Logger.ErrorMail("Onbewaarbare subscription","Event: "_Event.Type_", Status: "_$$ParseStatus^vhLib(Status))
+	} else {
+		while '..EventProcessed(WachtendEvent.%Id()) {
+			hang 0.2
+		}
 	}
 ]]></Implementation>
 </Method>
+
+<Method name="EventProcessed">
+<FormalSpec>EventID:%String</FormalSpec>
+<Private>1</Private>
+<ReturnType>%Boolean</ReturnType>
+<Implementation><![CDATA[
+	set Processed = ##class(TECH.PubSub.impl.WachtendEventStatus).%ExistsId(EventID)
+	if Processed {
+		set WachtendEventStatus = ##class(TECH.PubSub.impl.WachtendEventStatus).%OpenId(EventID)
+		set Processed = WachtendEventStatus.Status = "Gelukt"
+		if 'Processed { do ..MeldGefaaldeEvent(EventID) }
+	}
+	quit Processed
+]]></Implementation>
+</Method>
+
+<Method name="MeldGefaaldeEvent">
+<FormalSpec>EventID:%String</FormalSpec>
+<Private>1</Private>
+<Implementation><![CDATA[
+	if '..IsReedsGemeld(EventID) {
+		do ..Meld(EventID)
+		do ..RegistreerMelding(EventID)
+	}
+]]></Implementation>
+</Method>
+
+<Method name="IsReedsGemeld">
+<FormalSpec>EventID:%String</FormalSpec>
+<Private>1</Private>
+<Implementation><![CDATA[	quit ##class(TECH.PubSub.impl.GemeldeGefaaldeEvent).%ExistsId(EventID)
+]]></Implementation>
+</Method>
+
+<Method name="Meld">
+<FormalSpec>EventID:%String</FormalSpec>
+<Private>1</Private>
+<Implementation><![CDATA[
+	set From = $$$SystemMail("WachtendeEventAanmaker")
+	set To = $ListBuild("ict_sysop@vanhoecke.be")
+	set Body = ##class(%GlobalCharacterStream).%New()
+	do Body.WriteLine(" Event "_EventID_" is gefaald : ")
+	do Body.WriteLine(" momenteel staat processid "_$Job_" op "_$$$Server_" te lopen in een while lusken")
+	
+	do Body.WriteLine(" Verwerking event nakijken en eens OK status op Gelukt zettten via : ")
+	do Body.WriteLine("set E=##class(TECH.PubSub.impl.WachtendEventStatus).%OpenId("_EventID_") set E.Status = ##class(TECH.PubSub.enu.WachtendEventStatus).Gelukt() do E.Save()")
+	do Body.WriteLine($$GetJobInfo^vhLib()) 
+	Do SendMiniMail^vhLib.Mail(From,To,"!!!! Error event verwerking makova !!!!! - ( URGENT )",Body,1)
+]]></Implementation>
+</Method>
+
+<Method name="RegistreerMelding">
+<FormalSpec>EventID:%String</FormalSpec>
+<Private>1</Private>
+<Implementation><![CDATA[
+	set GemeldeGefaaldeEvent = ##class(TECH.PubSub.impl.GemeldeGefaaldeEvent).%New(EventID)
+	do GemeldeGefaaldeEvent.%Save()
+]]></Implementation>
+</Method>
 </Class>
 </Export>
Index: TECH/PubSub/impl/GemeldeGefaaldeEvent.cls.xml
===================================================================
diff -u
--- TECH/PubSub/impl/GemeldeGefaaldeEvent.cls.xml	(revision 0)
+++ TECH/PubSub/impl/GemeldeGefaaldeEvent.cls.xml	(revision 17777)
@@ -0,0 +1,45 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<Export generator="Cache" version="9">
+<Class name="TECH.PubSub.impl.GemeldeGefaaldeEvent">
+<ClassType>persistent</ClassType>
+<ProcedureBlock>1</ProcedureBlock>
+<Super>%Persistent</Super>
+<ClassDefinitionError>0</ClassDefinitionError>
+
+<Index name="MainIndex">
+<IdKey>1</IdKey>
+<Properties>EventID</Properties>
+</Index>
+
+<Property name="EventID">
+<Type>%String</Type>
+</Property>
+
+<Method name="%OnNew">
+<FormalSpec>EventID:%String=""</FormalSpec>
+<Private>1</Private>
+<ProcedureBlock>1</ProcedureBlock>
+<ReturnType>%Status</ReturnType>
+<Implementation><![CDATA[
+	set ..EventID = EventID
+	quit $$$OK
+]]></Implementation>
+</Method>
+
+<Storage name="Default">
+<Type>%Library.CacheStorage</Type>
+<DataLocation>^TECH.PubSub583.GemeldeGefaa7BED</DataLocation>
+<DefaultData>GemeldeGefaaldeEventDefaultData</DefaultData>
+<IdLocation>^TECH.PubSub583.GemeldeGefaa7BED</IdLocation>
+<IndexLocation>^TECH.PubSub583.GemeldeGefaa7BEI</IndexLocation>
+<StreamLocation>^TECH.PubSub583.GemeldeGefaa7BES</StreamLocation>
+<Data name="GemeldeGefaaldeEventDefaultData">
+<Structure>listnode</Structure>
+<Subscript/>
+<Value name="1">
+<Value>%%CLASSNAME</Value>
+</Value>
+</Data>
+</Storage>
+</Class>
+</Export>