create a rabbitmq class in javascript

index.tsx
const amqp = require('amqplib');

class RabbitMQ {
  constructor(url) {
    this.url = url;
    this.channel = null;
  }

  async connect() {
    const connection = await amqp.connect(this.url);
    this.channel = await connection.createChannel();
  }

  async sendMessage(queueName, message) {
    await this.channel.assertQueue(queueName, { durable: false });
    this.channel.sendToQueue(queueName, Buffer.from(message));
  }
}

// Example usage:
const rabbitmq = new RabbitMQ('amqp://localhost');
await rabbitmq.connect();
await rabbitmq.sendMessage('myQueue', 'Hello, RabbitMQ!');
586 chars
24 lines