1.0.1 • Published 1 year ago
@eduzz/rabbit v1.0.1
Eduzz RabbitMQ Client
This is an simplified and padronized RabbitMQ Client for NodeJS
How to use
Create a connection
import { Connection } from '@eduzz/rabbit';
export const myRabbit = new Connection({
dsn: 'amqp://...',
exchange: 'my-exchange'
});
Send an message to an topic:
import { myRabbit } from './myRabbit';
const payload = {
hello: 'world'
};
myRabbit.topic('some.topic').persistent().send({ payload });
Listen to one or multiple topics:
import { myRabbit } from './myRabbit';
myRabbit
.queue('my.queue')
.topic('some.topic')
.topic('another.topic')
.durable()
.retryTimeout(60000)
.listen(async data => {
console.log(data);
return true;
});
Full working demo
import { Connection } from '@eduzz/rabbit';
const connection = new Connection({
dsn: 'amqp://....',
exchange: 'theExchange',
exchangeType: 'topic',
connectionName: 'my app'
});
// Listening some topic
await connection
.queue('my.queue')
.topic('my.topic')
.durable()
.retryTimeout(60000)
.listen<string>(async msg => {
console.log(msg);
return true;
});
// Publishing message
(async () => {
const publisher = connection.topic('my.topic').persistent();
setInterval(async () => {
const payload = {
number: Math.random() * 1000
};
publisher.send({
payload
});
}, 1000);
})();
// Delaying Messages
connection.delayQueue('my.delay.queue').durable().from('from.topic').to('to.topic').timeout(5000).create();
1.0.1
1 year ago
1.0.0
2 years ago
1.0.0-beta.2
2 years ago
1.0.0-beta.3
2 years ago
1.0.0-beta.4
2 years ago
1.0.0-beta.5
2 years ago
1.0.0-beta.1
2 years ago
1.0.0-beta.10
2 years ago
1.0.0-next
2 years ago
1.0.0-beta.6
2 years ago
1.0.0-beta.7
2 years ago
1.0.0-beta.8
2 years ago
1.0.0-beta.9
2 years ago
0.4.0
2 years ago
0.3.0
3 years ago
0.3.1
3 years ago
0.2.1
3 years ago
0.2.0
4 years ago
0.1.4
4 years ago
0.1.3
4 years ago
0.1.2
4 years ago
0.1.0
5 years ago
0.1.1
5 years ago
0.0.10
5 years ago
0.0.9
5 years ago
0.0.8
5 years ago
0.0.7
5 years ago
0.0.6
5 years ago
0.0.5
5 years ago
0.0.4
5 years ago
0.0.3-1
5 years ago
0.0.3-0
5 years ago
0.0.2
5 years ago
0.0.1
6 years ago