'Register a callback for a given event type.'

def register_watcher(self, event_type, callback, register_timeout=None):

    self._push_watchers[event_type].add(callback)
    self.wait_for_response(RegisterMessage(event_list=[event_type]), timeout=register_timeout)
