falso-amqp

Falso AMQP - Node.js amqp-like server & client library

Falso AMQP is a AMQP-like server for Node.js. It client library is designed to be used exactly like amqplib with rabbitmq.

Support us

• or
• 

History

I was working with microservices in Node JS. The MS nodes were connected using RabbitMQ. My life was happy, until I've tried to deploy my project to azure. That was when I realize that the thing is was not so easy.

In order to use AMQP on Azure, I had two options:

1. Set up a virtual machine, and a Rabbit MQ server inside.
2. Use the AMQP service, provided by azure (you really have to control your messages exchange, otherwise it will be very expensive).

I just wanted a simpler think: deploy my microservices into an "app service" resource. Just that!

So, I decided to implement a AMQP-Like NodeJS Server and Client (library).

Getting started

You have two ways to implement the server.

Server (outside your project)

1. Install falso-amqp globally

npm i falso-amqp -g

2. Run it falso-amqp

Server (inside your project)

1. Install falso-amqp

npm i falso-amqp --save

2. Require

const runServer = require("falso-amqp");
 
runServer();

Client Library

npm i falso-amqp-client --save

Falso AMQP Client

The objetive of the Client library is to be compatible with Rabbit MQ.

Compatibility

Features based on amqplib channel api

• Channel API
• amqplib

| Function | Status | |----------------------------------|------------| |connect | OK | |ChannelModel and CallbackModel| | |connection.close | OK | |events | | |connection.createChannel | OK | |connection.createConfirmChannel | | |Channel | | |channel.close | | |events | | |channel.assertQueue | OK | |channel.checkQueue | | |channel.deleteQueue | | |channel.purgeQueue | | |channel.bindQueue | OK | |channel.unbindQueue | | |channel.assertExchange | OK | |channel.checkExchange | | |channel.deleteExchange | | |channel.bindExchange | | |channel.unbindExchange | | |channel.publish | OK | |channel.sendToQueue | OK | |channel.consume | OK | |channel.cancel | | |channel.get | | |channel.ack |In progress | |channel.ackAll | | |channel.nack |In progress | |channel.nackAll | | |channel.reject | | |channel.prefetch |In progress | |channel.recover | | |ConfirmChannel | | |confirmChannel.publish | | |confirmChannel.sendToQueue | | |confirmChannel.waitForConfirms | |