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' });