Adham Hashibon · 8c751d84 · 8c751d84 · 8c751d84 · 8c751d84 · 8c751d84
--- a/force_bdss/core_mco_driver.py
+++ b/force_bdss/core_mco_driver.py
+
+       return listeners
+
+   def _finalize_listener(self, listener):
+       """Helper method. Finalizes a listener and handles possible
+       exceptions. it does _not_ remove the listener from the listener
+       list.
+       """
+       try:
+           listener.finalize()
+       except Exception as e:
+           log.error(
+               "Exception while finalizing listener {}: {}".format(
+                   listener.__class__.__name__,
+                   str(e)
+               ))
--- a/force_bdss/core_plugins/dummy/dummy_notification_listener/dummy_notification_listener_factory.py
+++ b/force_bdss/core_plugins/dummy/dummy_notification_listener/dummy_notification_listener_factory.py
+from traits.api import String
+
+from force_bdss.api import (
+   factory_id,
+   BaseNotificationListenerFactory)
+
+from .dummy_notification_listener import DummyNotificationListener
+from .dummy_notification_listener_model import DummyNotificationListenerModel
+
+
+class DummyNotificationListenerFactory(BaseNotificationListenerFactory):
+   id = String(factory_id("enthought", "dummy_notification_listener"))
+
+   name = String("Dummy Notification Listener")
+
+   def create_model(self, model_data=None):
--- a/force_bdss/core_plugins/dummy/ui_notification/ui_notification.py
+++ b/force_bdss/core_plugins/dummy/ui_notification/ui_notification.py
+   Notification engine for the UI. Uses zeromq for the traffic handling.
+   """
+   #: The ZMQ context. If None, it means that the service is unavailable.
+   _context = Instance(zmq.Context)
+
+   #: The pubsub socket.
+   _pub_socket = Instance(zmq.Socket)
+
+   #: The synchronization socket to communicate with the server (UI)
+   _sync_socket = Instance(zmq.Socket)
+
+   #: Unique identifier from the UI. To be returned in the protocol.
+   _identifier = String()
+
+   #: The protocol version that this plugin delivers
+   _proto_version = "1"
--- a/force_bdss/mco/events.py
+++ b/force_bdss/mco/events.py
+   """Base event for the MCO"""
+
+
+class MCOStartEvent(BaseMCOEvent):
+   """MCO should emit this event when the evaluation starts."""
+
+
+class MCOFinishEvent(BaseMCOEvent):
+   """MCO should emit this event when the evaluation ends."""
+
+
+class MCOProgressEvent(BaseMCOEvent):
+   """MCO should emit this event for every new evaluation that has been
+   completed. It carries data about the evaluation, specifically the
+   input data (MCO parameter values) and the resulting output (KPIs)."""
+   input = Tuple()
--- a/force_bdss/core_plugins/dummy/ui_notification/ui_notification.py
+++ b/force_bdss/core_plugins/dummy/ui_notification/ui_notification.py
+import logging
+from traits.api import Instance, String
+
+from force_bdss.api import (
+   BaseNotificationListener,
+   MCOStartEvent,
+   MCOFinishEvent,
+   MCOProgressEvent
+)
+
+import zmq
+
+log = logging.getLogger(__name__)
+
+
+class UINotification(BaseNotificationListener):