Skip to main content

Rabbit MQ wrapper implement with amqpstorm and with threading or multiprocessing

Project description

rmqworkers -- Manage dynamic workers rabbitmq for Python applications


Project rmqworkers offer high availability through simple, yet powerful library: This library doesn't work as a standalone.

This project require a rabbitmq server.

Please note that for development I've used a container:

How to run

docker run -d --hostname my-rabbit --name rabbitmq-server -p 15672:15672 -p 5672:5672 rabbitmq:3-management

Default has credentials: user: quest passw: quest

cd rmqworkers/examples

source venv/bin/activate or venv/Scripts/

pip install -r requirements.txt


Expected output

Default will use thread.

publish in queue in { "job_info": "11111"}

Verify if in queue out is {'job_info': '11111!!!!!!!', 'add_something': 'something'}

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

rmqworkers-0.0.4.tar.gz (5.9 kB view hashes)

Uploaded source

Built Distribution

rmqworkers-0.0.4-py3-none-any.whl (9.9 kB view hashes)

Uploaded py3

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page