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"
# 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.4.tar.gz
(3.2 kB
view hashes)
Built Distribution
Close
Hashes for rabbitmq_toolkit-0.1.4-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 392877a5e1a4ee5b24379ed1878d7f3d5d39014b5d92e0856215b6075501ffb2 |
|
MD5 | d5d7b767086dc68f515cbaaecd725642 |
|
BLAKE2b-256 | 80dea2b483e76a5e7fb8f935cbb22fcc0b5a640715c3887691926dc3170086e4 |