Se habilita la funcionalidad de mensajería externa con RabbitMQ
El siguiente ejemplo esta hecho en Javascript (NodeJS). Desde https://www.rabbitmq.com/tutorials/tutorial-one-javascript.html se pueden ver otros ejemplos en diferentes lenguajes de programación
#!/usr/bin/env node
var amqp = require('amqplib/callback_api');
amqp.connect('amqp://[user]:[pass]@localhost', function(error0, connection) {
if (error0) {
throw error0;
}
connection.createChannel(function(error1, channel) {
if (error1) {
throw error1;
}
var queue = 'news';
var msg = JSON.stringify({name:'Noticia', description:'Nueva noticia', version:100});
channel.assertQueue(queue, {
durable: false
});
channel.sendToQueue(queue, Buffer.from(msg));
console.log(" [x] Sent %s", msg);
});
}); |
amqp://[user]:[pass]@localhost hay que reemplazarlo por las credenciales e IP correspondientes
#!/usr/bin/env node
var amqp = require('amqplib/callback_api');
amqp.connect('amqp://[user]:[pass]@localhost', function(error0, connection) {
if (error0) {
throw error0;
}
connection.createChannel(function(error1, channel) {
if (error1) {
throw error1;
}
var queue = 'news';
channel.assertQueue(queue, {
durable: false
});
console.log(" [*] Waiting for messages in %s. To exit press CTRL+C", queue);
channel.consume(queue, function(msg) {
console.log(" [x] Received %s", JSON.parse(msg.content.toString()));
}, {
noAck: true
});
});
});
|
amqp://[user]:[pass]@localhost hay que reemplazarlo por las credenciales e IP correspondientes