skip to navigation
skip to content

Not Logged In

djamqpconsumer 0.5

Blocking custom django command to consume a AMQP queue

Latest Version: 0.7

What is this

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]

0.5 (2014-02-21)

  • Add pika dependency
 
File Type Py Version Uploaded on Size
djamqpconsumer-0.5.zip (md5) Source 2014-02-21 6KB
  • Downloads (All Versions):
  • 54 downloads in the last day
  • 275 downloads in the last week
  • 1259 downloads in the last month