A streamlined toolkit for efficient RabbitMQ operations.
Project description
RabbitMQ Toolkit
RabbitMQ Toolkit is a comprehensive package designed to simplify RabbitMQ operations. It encapsulates the core functionalities into three intuitive classes: QueueManager
, Producer
, and Consumer
, streamlining the process of message queueing, producing, and consuming.
Installation
Install the package via pip:
pip install rabbitmq_toolkit
Features
- QueueManager: Effortlessly manage your RabbitMQ queues.
- Producer: Produce messages with ease, ensuring they're properly queued.
- Consumer: Robustly consume messages, with built-in mechanisms to handle common scenarios.
Usage Example
Producer
In producer.py
:
from rabbitmq_toolkit import QueueManager, Producer
# Initialize the Queue Manager and declare a queue
queue_mgr = QueueManager()
queue_name = "sample_queue"
queue_mgr.declare_queue(queue_name)
# Produce a message
producer = Producer(queue_mgr)
producer.send_message(queue_name, "Hello from RabbitMQ Toolkit!")
Run producer.py
in terminal:
python producer.py
Consumer
In consumer.py
:
from rabbitmq_toolkit import QueueManager, Consumer
# Initialize the Queue Manager
queue_mgr = QueueManager()
queue_name = "sample_queue"
# We use declare_queue for both can operate independently and can be started in any order.
queue_mgr.declare_queue(queue_name)
# Consume the message
def callback(message):
print(f"Received: {message}")
consumer = Consumer(queue_mgr)
consumer.start_consuming(queue_name, callback)
Run consumer.py
in other tab terminal:
python consumer.py
Note: This provides a clear distinction between the Producer and Consumer, showcasing how they can be used in separate files.
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
rabbitmq_toolkit-0.1.7.tar.gz
(3.7 kB
view hashes)
Built Distribution
Close
Hashes for rabbitmq_toolkit-0.1.7-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 1037431baa81d19b5da7bb84853023e55e0cb1ab66d9d12201a82c8bf13b423e |
|
MD5 | c86ae77319a3fadb16080d9ed0882eb8 |
|
BLAKE2b-256 | ab294602213db69dea3a41971f8ea2517f46ce7765d51cc5d2f5d394dd661711 |