rabbitmq-clients 0.1.7

High level interfaces for work with RabbitMQ.

Stack:

• Python 3.11+
  
• aio-pika 9.4.1+
  

Installation

pip install rabbitmq-clients

Usage

Producer

import asyncio
import json

from rabbitmq_clients import RabbitProducer

if __name__ == "__main__":
    publisher = RabbitProducer(
        host='localhost',
        login='test',
        password='test',
        queue_name='test_queue',
        exchange_name='',
        routing_key='',
    )
    data = {"result": True}
    asyncio.run(publisher.publish(json.dumps(data)))

Consumer

import asyncio

from rabbitmq_clients import RabbitConsumer
from rabbitmq_clients.core.types import JSON


async def show_result(result: JSON):
    print(result)


if __name__ == "__main__":
    consumer = RabbitConsumer(
        host='localhost',
        login='test',
        password='test',
        queue_name='test_queue',
    )
    try:
        asyncio.run(consumer.consume(on_message_callback=show_result))
    except KeyboardInterrupt:
        pass