Welcome to MenashMQ!

Easy to use RabbitMQ abstraction with auto-reconnect for JavaScript and TypeScript

Examples

Initialize once - use everywhere:

index.js

const { menash } = require('menashmq');

await menash.connect('amqp://localhost');
await menash.declareQueue('my-queue', { durable: true });

manager.js

const { menash } = require('menashmq');

await menash.send('my-queue', "I'm using MenashMQ");

Declare your topology easily in one place:

const { menash } = require('menashmq');

// Simple consume function
const consume = (msg) => {
	console.log(msg.getContent());
};

await menash.declareTopology({
	exchanges: [
		{ name: 'first-exchange', type: 'fanout', options: { durable: false } },
		{ name: 'second-exchange', type: 'direct' },
		{ name: 'third-exchange', type: 'topic' },
	],
	queues: [
		{ name: 'queue1', options: { durable: false } },
		{ name: 'queue2' },
		{ name: 'queue3' },
		{ name: 'queue4' },
	],
	bindings: [
		{ source: 'first-exchange', destination: 'queue1' },
		{ source: 'second-exchange', destination: 'queue2' },
		{ source: 'third-exchange', destination: 'queue3', pattern: "*.menash" },
		{ source: 'third-exchange', destination: 'queue4', pattern: "monkey.#" },
	],
	consumers: [
		{ queueName: 'queue1', onMessage: consume },
		{ queueName: 'queue2', onMessage: consume, options: { noAck: true } },
	]
});

TypeScript support

MenashMQ is written in Typescript and supports it perfectly!

index.ts

import menash from 'menashmq';

await menash.connect('amqp://localhost');
await menash.declareQueue('menash-queue');

produce.ts

import menash from 'menashmq';

await menash.send('menash-queue', { name: 'menash', type: 'monkey' });

consume.ts

import menash, { ConsumerMessage } from 'menashmq';

await menash.queue('menash-queue').activateConsumer((msg: ConsumerMessage) => {
	const animal = msg.getContent() as IAnimal;
	console.log('Name:', animal.name);
	console.log('Type:', animal.type);

	msg.ack();
}, { noAck: false });

Upcoming features:

• add support for JSON RPC over RabbitMQ

API

Client

Methods:

• connect()

• close()

• bind()

• declareQueue()

• deleteQueue()

• declareExchange()

• deleteExchange()

• declareTopology()

• send()

• queue()

• exchange()

Events:

• close

• error

• ready

Exchange

Methods:

• bind()

• delete()

• send()

Queue

Methods:

• activateConsumer()

• stopConsumer()

• bind()

• delete()

• prefetch()

• send()

ConsumerMessage

Methods:

• setContent()

• getContent()

• getRawContent()

• ack()

• nack()

• reject()