code: def notify(self, correlation_id, args):
          
          for listener in self._listeners:
              try:
                  listener.on_event(correlation_id, self, args)
              except Exception as ex:
                  raise InvocationException(
                      correlation_id,
                      "EXEC_FAILED",
                      "Raising event " + self._name + " failed: " + str(ex)
                  ).with_details("event", self._name).wrap(ex)
docs: Fires this event and notifies all registred listeners.
  
          :param correlation_id: (optional) transaction id to trace execution through call chain.
  
          :param args: the parameters to raise this event with.