اتصال به RabbitMQ در برنامه‌های NextJS

npm install amqplib

RABBITMQ_HOST=fitz-roy.liara.cloud
RABBITMQ_PORT=32923
RABBITMQ_USER=root
RABBITMQ_PASS=63LVuatIrWWajE7gxSj20gHL

import amqp from 'amqplib';

const rabbitConfig = {
protocol: 'amqp',
hostname: process.env.RABBITMQ_HOST,
port: parseInt(process.env.RABBITMQ_PORT, 10),
username: process.env.RABBITMQ_USER,
password: process.env.RABBITMQ_PASS,
};

export default async function handler(req, res) {
try {
  const connection = await amqp.connect(rabbitConfig);
  await connection.close();
  res.status(200).json({ message: 'connection successful' });
} catch (error) {
  res.status(500).json({ message: 'connection failed!', error: error.message });
}
}

npm install amqplib

RABBITMQ_HOST=fitz-roy.liara.cloud
RABBITMQ_PORT=32923
RABBITMQ_USER=root
RABBITMQ_PASS=63LVuatIrWWajE7gxSj20gHL

import amqp from 'amqplib';

const rabbitConfig = {
protocol: 'amqp',
hostname: process.env.RABBITMQ_HOST,
port: parseInt(process.env.RABBITMQ_PORT, 10),
username: process.env.RABBITMQ_USER,
password: process.env.RABBITMQ_PASS,
};

export async function GET() {
try {
  const connection = await amqp.connect(rabbitConfig);
  await connection.close();
  return new Response(JSON.stringify({ message: 'connection successful' }), {
    status: 200,
  });
} catch (error) {
  return new Response(
    JSON.stringify({ message: 'connection failed', error: error.message }),
    { status: 500 }
  );
}
}