diff --git a/Nasal/emesary.nas b/Nasal/emesary.nas index 41a65d034..1ba6f7bfa 100644 --- a/Nasal/emesary.nas +++ b/Nasal/emesary.nas @@ -53,7 +53,10 @@ var Transmitter = { append(me.Recipients, recipient); }, - + DeleteAllRecipients: func + { + me.Recipients = []; + }, # Stops a recipient from receiving notifications from this transmitter. DeRegister: func(todelete_recipient) { @@ -95,6 +98,10 @@ var Transmitter = # allows for usages such as access controls. NotifyAll: func(message) { + if (message == nil){ + print("Emesary: bad notification nil"); + return Transmitter.ReceiptStatus_NotProcessed; + } var return_status = Transmitter.ReceiptStatus_NotProcessed; foreach (var recipient; me.Recipients) { diff --git a/Nasal/emesary_mp_bridge.nas b/Nasal/emesary_mp_bridge.nas index 83536bae8..4f0eb7994 100644 --- a/Nasal/emesary_mp_bridge.nas +++ b/Nasal/emesary_mp_bridge.nas @@ -90,7 +90,7 @@ var OutgoingMPBridge = foreach(var n ; new_class.NotificationsToBridge) { - print(" Outward bridge notifications of type --> ",n.NotificationType); + print(" ",_ident," outwards bridge[",n,"] notifications of type --> ",n.NotificationType, " Id ",n.TypeId); n.MessageIndex = OutgoingMPBridge.StartMessageIndex; new_class.NotificationsToBridge_Lookup[n.TypeId] = n; }