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 = “Username” COM_PASSWORD = “Password” COM_QUEUE = ‘Which queue listen to’ CONSUMER_CALLBACK = ‘Path to the callback func. ex.: djamqpconsumer.printconsumer.printdata’
Install
pip install djamqpconsumer
Usage
Add djamqpconsumer to your INSTALLED_APPS run manage.py consumer
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.1.zip
(5.3 kB
view hashes)
