Blocking custom django command to consume a AMQP queue
Project description
Adds a custom command which opens a blocking connection with an AMQP server and passes messages to a callback fuction
Settings
This settings are requiered for the command run
COM_BROKER
AMQP server ip
COM_VHOST
AMQP server Virtual Host
COM_USERNAME
AMQP server User name for the virtual host
COM_PASSWORD
Username’s password
COM_QUEUE
Which queue listen to
CONSUMER_CALLBACK
Path to the callback func. ex.: djamqpconsumer.printconsumer.printdata
Install
Use pip to install from PyPI:
pip install djamqpconsumer
Usage
Add djamqpconsumer to your settings.py file:
INSTALLED_APPS = (
...
'djamqpconsumer',
...
)
Use with manage.py:
manage.py consumer [debug]
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
djamqpconsumer-0.3.zip
(5.1 kB
view hashes)
