С какими брокерами сообщений работал

import pika

def test_message_consumption():
    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
    channel = connection.channel()
    channel.queue_declare(queue='test_queue')
    
    channel.basic_publish(exchange='', routing_key='test_queue', body='test_msg')
    method_frame, _, body = channel.basic_get(queue='test_queue')
    
    assert body.decode() == 'test_msg'
    channel.basic_ack(method_frame.delivery_tag)
    connection.close()