2.0.14 • Published 6 years ago
hinos-rabbitmq v2.0.14
hinos-rabbitmq
A plugin helps to manage rabbitmq connection for hinos
Install
npm i hinos-rabbitmq -S
Examples
Typescript
Config mongo information
import { RabbitMQ } from 'hinos-rabbitmq';
RabbitMQ({
url: 'amqp://127.0.0.1',
releaseTimeout: 60000,
queue: {
'API_RECEIVER': {
des: 'Listen queue message for API',
getListenerName: (_data: any) => `${AppConfig.mqtt.queue.API_RECEIVER}`,
getError: (data: any) => !data.error ? null : data.error || 'Unknown'
}
}
}).debug(!Server.isProduction)
RabbitMQ({
key: 'connection1',
url: 'amqp://192.168.0.56',
queue: {
'LOG_RECEIVER': {
des: 'Listen queue message for Log realtime',
getListenerName: (_data: any) => `${AppConfig.mqtt.queue.LOG_RECEIVER}`,
getError: (data: any) => !data.error ? null : data.error || 'Unknown'
}
}
})
Use in service file
import { RABBITMQ, RabbitMQ, RabbitListener } from 'hinos-rabbitmq'
@RabbitListener({
des: 'Test rabbitmq',
queue: 'LOG_RECEIVER',
listenerName: AppConfig.mqtt.queue.API_RECEIVER,
onHandler(err, data) {
console.log(err, data)
}
})
export class ChartService {
@RABBITMQ()
private static rabbitMQ: RabbitMQ
@MQTT('connection1')
static rabbitMQ1: RabbitMQ;
static async sendToRabbit(data: any = {}) {
ChartService.rabbitMQ.send('queueName', data);
}
}
2.0.14
6 years ago
2.0.13
6 years ago
2.0.12
6 years ago
2.0.11
6 years ago
2.0.10
6 years ago
2.0.9
6 years ago
2.0.8
6 years ago
2.0.7
6 years ago
2.0.6
6 years ago
2.0.5
7 years ago
2.0.4
7 years ago
2.0.3
7 years ago
2.0.2
7 years ago
2.0.1
7 years ago
2.0.0
7 years ago
1.0.5
7 years ago
1.0.4
7 years ago
1.0.3
7 years ago
1.0.2
7 years ago
1.0.1
7 years ago
1.0.0
7 years ago