RABBITMQ CLIENT CONNECTION PYTHON TEST

rabbitmq.py

import pika
from bottle import run, Bottle

EXCHANGE_NAME = "domain"
QUEUE_NAME = "domain"
ROUTING_EX_KEY = "domain-key"


def main():
    rabbitmq_uri_app = "amqp://user:[email protected]:5672/target-vhost"
    connection = pika.BlockingConnection(pika.URLParameters(rabbitmq_uri_app))
    app = Bottle()

    ch = connection.channel()

    @app.post('/message/<your_message>')
    def hello(your_message: str):
        msg_to_rabbitmq = bytes(your_message, encoding='utf8')
        ch.basic_publish(EXCHANGE_NAME, routing_key=ROUTING_EX_KEY, body=msg_to_rabbitmq)
        return your_message

    @app.get('/messages')
    def get_last_message():
        _, _, body = ch.basic_get(queue=QUEUE_NAME, auto_ack=True)
        return body.decode('utf-8') if body else "La queue esta vacia"

    run(app, host='0.0.0.0', port=5000, debug=True)


if __name__ == '__main__':
    main()