Haredo - A type-safe rabbitmq client

Typescript example

import { Haredo, Queue } from 'haredo';
const rabbit = Haredo({
    url: 'amqp://localhost:5762'
});

interface MyMessage {
    id: number;
    status: string;
}

const myQueue = Queue<MyMessage>('myqueue');

rabbit.queue(myQueue)
    .subscribe(data => {
        console.log(data);
    });

rabbit.queue(myQueue)
    .publish({
        id: 1,
        status: 'active'
    });

Javascript example (with queue shorthand)

const { Haredo } = require('haredo');
const rabbit = Haredo({
    url: 'amqp://localhost:5762'
});

rabbit.queue('myqueue')
    .subscribe(message => {
        console.log(message);
    });

rabbit.queue('myqueue')
    .publish({ id: 1, status: 'active' });