amqplibrary-ts v1.0.4

INSTALLATION

npm install --save amqplibrary-ts

Setting up a connection

import { amqp } from 'amqplibrary-ts';

async function main() {
    await amqp.connect('amqp://localhost:5672');
}

Usage

request-reply

import { Reply, Request } from 'amqplibrary-ts';

Process A:

// receive a request
interface Add {
    num1: number
    num2: number
}

new Reply<Add>('request-reply-queue')
    .listen((message) => {
        const num1 = message.data.num1;
        const num2 = message.data.num2;

        return num1 + num2;
    });

Process B:

interface Add {
    num1: number
    num2: number
}

// send a request
const response = await new Request<Add>('request-reply-queue').send({ num1: 10, num2: 15 });
console.log(response) // 25

send - listen

import { Listener, Sender } from 'amqplibrary-ts';

Process A:

interface Message {
    greet: string
}

// listen to an event
new Listener<Message>('send-listen-queue')
    .listen(async (message) => {
        console.log(message.data.greet); // 'Hello' 

        message.ack(); // acknowledge message
        // message.reject(); // reject message
    });

Process B:

interface Message {
    greet: string
}

new Sender<Message>('send-listen-queue')
            .send({ greet: 'Hello' });

publish - subscribe

import { Subscriber, Publisher } from 'amqplibrary-ts';

Process A:

interface Message {
    greet: string
}

const exchange = 'broadcast';
const queue = 'broadcast-queue1';

new Subscriber<Message>(exchange, queue)
    .listen(async (message) => {
        console.log(message.data.greet); // 'Hello, this is a broadcast message' 

        message.ack(); // acknowledge message
        // message.reject(); // reject message
    });

Process B:

interface Message {
    greet: string
}

const exchange = 'broadcast';
const queue = 'broadcast-queue2';

new Subscriber<Message>(exchange, queue)
    .listen(async (message) => {
        console.log(message.data.greet); // 'Hello, this is a broadcast message' 

        message.ack(); // acknowledge message
        // message.reject(); // reject message
    });

Process C:

interface Message {
    greet: string
}

const exchange = 'broadcast';

new Publisher<Message>(exchange)
            .send({ greet: 'Hello, this is a broadcast message' });