اتصال به RabbitMQ در برنامه‌های Flask و NodeJS

from flask import Flask, jsonify
import pika

app = Flask(__name__)

rabbitmq_url = "some uri"
parameters = pika.URLParameters(rabbitmq_url)

@app.route('/send_message', methods=['POST'])
def send_message():
    connection = pika.BlockingConnection(parameters)
    channel = connection.channel()

    channel.queue_declare(queue='test_queue')

    message = "Hello from Flask producer!"
    channel.basic_publish(exchange='', routing_key='test_queue', body=message)
    connection.close()

    return jsonify({"message": "Message sent to RabbitMQ!"})

if __name__ == "__main__":
    app.run(port=5000)

const amqp = require('amqplib');

const rabbitmqUrl = "some uri";

async function consume() {
  try {
    const connection = await amqp.connect(rabbitmqUrl);
    const channel = await connection.createChannel();

    await channel.assertQueue('test_queue', { durable: false });

    console.log("Waiting for messages in 'test_queue'...");

    channel.consume('test_queue', (msg) => {
      if (msg !== null) {
        console.log("Received:", msg.content.toString());
        channel.ack(msg);
      }
    });
  } catch (error) {
    console.error("Error:", error);
  }
}

consume();