A generic queue client
Project description
### Project description
Based on the kombu, pika
**must kombu==3.0.35**
*The sample code*
```python
def worker(data):
...
return SUCCESS
consumer = Consumer("amqp://account:password@ip:port/vhost", "queue", worker)
consumer.run()
```
打包命令
python3 setup.py sdist
python3 setup.py sdist upload
python3 setup.py bdist_wheel --universal
python3 setup.py bdist_wheel upload
Based on the kombu, pika
**must kombu==3.0.35**
*The sample code*
```python
def worker(data):
...
return SUCCESS
consumer = Consumer("amqp://account:password@ip:port/vhost", "queue", worker)
consumer.run()
```
打包命令
python3 setup.py sdist
python3 setup.py sdist upload
python3 setup.py bdist_wheel --universal
python3 setup.py bdist_wheel upload
Project details
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.1.9.tar.gz
(11.4 kB
view hashes)
Built Distribution
ampq_cl-0.1.9-py3-none-any.whl
(12.4 kB
view hashes)