A generic queue client
Project description
Python version must be greater than 3.7.1
Based on the package
kombu==3.0.35
pika==0.13.1
The sample code
- ::
- def worker(data):
… return SUCCESS
consumer = Consumer(“amqp://account:password@ip:port/vhost”, “queue”, worker) consumer.run()
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
ampq_cl-0.2.1.tar.gz
(15.2 kB
view hashes)
Built Distribution
ampq_cl-0.2.1-py3-none-any.whl
(18.3 kB
view hashes)
