Skip to main content

Blocking custom django command to consume a AMQP queue

Project description

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

Project details


Release history Release notifications

History Node

0.7

This version
History Node

0.5

History Node

0.4

History Node

0.3

History Node

0.1

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Filename, size & hash SHA256 hash help File type Python version Upload date
djamqpconsumer-0.5.zip (6.4 kB) Copy SHA256 hash SHA256 Source None Feb 21, 2014

Supported by

Elastic Elastic Search Pingdom Pingdom Monitoring Google Google BigQuery Sentry Sentry Error logging CloudAMQP CloudAMQP RabbitMQ AWS AWS Cloud computing Fastly Fastly CDN DigiCert DigiCert EV certificate StatusPage StatusPage Status page