Onify fake-amqplib

Mocked version of https://www.npmjs.com/package/amqplib.

Overriding amqplib

You might want to override amqplib with @onify/fake-amqplib in tests. This can be done this way:

const amqplib = require('amqplib');
const fakeAmqp = require('@onify/fake-amqplib');

amqplib.connect = fakeAmqp.connect;

If you are using version 2 or higher of exp-amqp-connection you can use mock-require to replace amqplib with @onify/fake-amqplib in your tests like this:

const mock = require('mock-require');
const fakeAmqp = require('@onify/fake-amqplib');

mock('amqplib/callback_api', fakeAmqp);

or just mock the entire amqplib with

const mock = require('mock-require');
const fakeAmqp = require('@onify/fake-amqplib');

mock('amqplib', fakeAmqp);

RabbitMQ versions

Some behaviour differs between versions. To specify your version of RabbitMQ you can call setVersion(minorVersionFloatOrString). Default version is 3.5.

Example:

var fakeAmqp = require('@onify/fake-amqplib');

// prepare your connections
(async () => {
  fakeAmqp.setVersion('2.2');
  const conn2 = await fakeAmqp.connect('amqp://rabbit2-2');

  fakeAmqp.setVersion('3.2');
  const conn3 = await fakeAmqp.connect('amqp://rabbit3-1');

  fakeAmqp.setVersion('3.7');
  const conn37 = await fakeAmqp.connect('amqp://rabbit3-7');
})()

Fake api

List of available methods and a property

• connections: property with all faked connections
• connectSync(amqpurl[, ...otherOptions]): helper method to create a connection without waiting for promise to resolve - synchronous
• resetMock(): reset all connections and brokers
• setVersion(minor): next connection will be to a amqp of a specific version
• async connect(amqpurl[, ...otherOptions, callback]): make a fake connection