The Moksha Hub¶
MokshaHub¶
Moksha provides a moksha.hub.MokshaHub class that makes it simple for applications to send messages to a given topic.
from moksha.hub.api import MokshaHub, reactor
hub = MokshaHub()
hub.send_message('topic', 'message')
reactor.run()
hub.close()
Behind the scenes, the MokshaHub will automatically connect up to whatever message brokers are configured, and create a new session. The send_message() method will automatically handle encoding your message to JSON (unless you pass jsonify=False), and sending it to the appropriate message broker.
CentralMokshaHub¶
The CentralMokshaHub is the primary consumer of all message topics. It runs outside of the Moksha WSGI application stack, and is automatically started by the $ ./moksha-ctl.py start or $ ./moksha-ctl.py start:moksha-hub commands (and can be started manually by running moksha-hub).
The CentralMokshaHub currently handles the following tasks:
