queue_helpers

This package is a helper that is used to manage queues in RabbitMQ.

Installing

pip install queue_helpers

Usage

>>> from queue_helpers import RpcClient
>>> def send_rpc_message(queue_name, request, rabbit_username, rabbit_password, rabbitserver, vhost):
...     client = RpcClient(rabbit_server_host=rabbitserver,
...                        virtual_host=vhost,
...                        server_queue_name=queue_name,
...                        username=rabbit_username,
...                        password=rabbit_password)
...     resp = client.call(json.dumps(request))
...     response = json.loads(resp.decode("utf-8"))
...     return response