It would be a great addition some usage examples 😄

I've used with Jest: <div class="highlight highlight-source-js notranslate positio

how to use it? I think that this is very unfriendly <g-emoji class="g-emoji" alias="c

I've used like this <div class="highlight highlight-source-js notranslate position

Add usage examples about amqplib-mocks HOT 4 OPEN

bunk commented on June 30, 2024 10

Add usage examples

from amqplib-mocks.

Comments (4)

tn commented on June 30, 2024 1

I've used with Jest:

import amqplib from 'amqplib-mocks'
jest.setMock('amqplib', amqplib)

from amqplib-mocks.

0Ams commented on June 30, 2024

how to use it? I think that this is very unfriendly 😢

from amqplib-mocks.

trycontrolmymind commented on June 30, 2024

I've used like this

// Rabbit.ts
let amqp;
if (process.env["NODE_ENV"] === "test") {
  amqp = require("amqplib-mocks");
} else {
  amqp = require("amqplib");
}

// Test.spec.ts
const amqp = require("amqplib-mocks");

let rabbit = null;
beforeEach(() => {
  rabbit = new Rabbit("amqp://localhost");
});

afterEach(() => {
  amqp.reset();
});

and it works ok.

from amqplib-mocks.

Rajanusa commented on June 30, 2024

I use jest for unit testing and need to unit test this code
Please advise, how this library can be used for unit test this method.
I tried 'tn' approach, it is not working

 publish(queueName: string, message: string) {
    const rabbitMQOption = this.config.getRabbitmqOption(queueName);
    if (!rabbitMQOption) {
      throw Error('Connection string does not exist');
    } else {
      const conn = amqp
        .connect(rabbitMQOption.connection)
        .then((conn) => {
          return conn
            .createChannel()
            .then((ch) => {
              const ex = rabbitMQOption.exchangeName;
              const ok = ch.assertExchange(ex, rabbitMQOption.exchangeType, {
                durable: false,
              });
              return ok.then(() => {
                ch.publish(ex, '', Buffer.from(message));
                return ch.close();
              });
            })
            .finally(() => {
              conn.close();
            });
        })
        .catch(console.warn);
    }
  }
}