diff --git a/rida/messaging.py b/rida/messaging.py index 44eddfee..8750685b 100644 --- a/rida/messaging.py +++ b/rida/messaging.py @@ -32,6 +32,7 @@ def publish(topic, msg, backend, modname='rida'): raise KeyError("No messaging backend found for %r" % backend) return handler(topic, msg, modname=modname) + def listen(backend, **kwargs): """ Yield messages from a given messaging backend.