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.5.tar.gz
(3.8 kB
view hashes)
Built Distribution
Close
Hashes for rabbitmq_toolkit-0.1.5-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 5ee09834d9fd1ebcff3ea0225d0cca1e69699143cf1428e0f55a158aef8a37ae |
|
MD5 | 67ccc3f423b7389ad61781174b717166 |
|
BLAKE2b-256 | 21a2ccfabeca2f5a996c18c4721873a1e1f20338ee4ab06a43e8492f774bd872 |