Add methods to register and register message handlers to GStreamer

This commit is contained in:
Thomas Adamcik 2011-05-16 21:53:01 +02:00
parent fae784b71e
commit 943645aecf

View File

@ -41,6 +41,7 @@ class GStreamer(ThreadingActor):
self._uridecodebin = None
self._volume = None
self._outputs = []
self._handlers = {}
def on_start(self):
self._setup_gstreamer()
@ -292,3 +293,9 @@ class GStreamer(ThreadingActor):
pad.set_blocked(False)
logger.warning(u'Removed %s', output.get_name())
def connect_message_handler(self, element, handler):
self._handlers[element] = handler
def remove_message_handler(self, element):
self._handlers.pop(element, None)