1.0.0 • Published 4 years ago
@alirezazeynali/rabbitmq v1.0.0
rabbitmq
RabbitMq agent
In javascript
const {Queue} = require('@alirezazeynali/rabbitmq')
const queue = new Queue('url', {durable: true}, true)
queue.send('queue_name', data)
queue.consumer('queue_name', 'event')
queue.on ('event', (msg) => {
// do with msg
})
In typescript
import {Queue} from '@alirezazeynali/rabbitmq'
1.0.0
4 years ago