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 import MokshaHub
hub = MokshaHub()
hub.send_message('topic', 'message')
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 start-moksha script.

The CentralMokshaHub currently handles the following tasks:

• Consumes all messages from STOMP and AMQP brokers
• Feeds Consumers new messages for specific topics
• Runs all of the DataStreams