PyRMQ

Python with RabbitMQ—simplified so you won’t have to.

Features

Stop worrying about boilerplating and implementing retry logic on your queues. PyRMQ already does it for you.

• Use out-of-the-box and thread-safe Consumer and Publisher classes created from pika for your projects and tests.

• Built-in retry-backoff logic for connecting, consuming, and publishing.

• Works with Python 3.

• Production ready

Quickstart

PyRMQ is available at PyPI.

$ pip install pyrmq

Just instantiate the feature you want with their respective settings. PyRMQ already works out of the box with RabbitMQ’s default initialization settings.

from pyrmq import Publisher
publisher = Publisher(
    exchange_name="exchange_name",
    queue_name="queue_name",
    routing_key="routing_key",
)
publisher.publish({"pyrmq": "My first message"})

User Guide

• Installation
  • Stable Version
  • Development Version
    • Git Checkout
    • PyPI
• Usage
  • Publishing
    • Retries
    • Connecting
    • Publishing
    • Max retries reached
  • Consuming
    • Retries
    • Connecting
    • Consuming
    • Max retries reached
• API
  • Publisher Class
  • Consumer Class
• Testing
  • RabbitMQ
    • Run Docker image (recommended)
    • Install and run RabbitMQ locally
  • Using tox