Documentation for pulsar 0.7.2. For development docs, go here.
The code for this example is located in the examples.taskqueue.manage module.
This example creates two pulsar applications performing different duties. The first application is a distributed a task queue for processing tasks implemented in the examples.taskqueue.simpletasks module. The second application is a WSGI server which exposes the task queue functionalities via a JSON-RPC api.
To run the server type:
Open a new shell and launch python and type:
>>> from pulsar.apps import rpc >>> p = rpc.JsonProxy('http://localhost:8060') >>> p.ping() 'pong' >>> p.calc.add(3,4) 7.0 >>>
The pulsar.apps.rpc.JSONRPC handler which communicates with the task queue.
Build a multi-app consisting on a taskqueue and a JSON-RPC server.