npm install
Rename /config.js.example to /config.js and change settings
You need to link some scripts
<script src="/js/socket.io.js"></script>
<script src="/js/br.rabbitMQ.js"></script>
Then you can use proxy as easy as in following example
$(document).ready(function() {
var rmq = br.rabbitMQ({port: 8080});
rmq.subscribe('exchange', '*.task', function(data) {
console.log(data);
});
rmq.subscribe('exchange', '*.person', function(data) {
console.log(data);
});
});
subscribe(exchangeName, topic, callback)
You need to install PHP AMPQ library (https://github.com/videlalvaro/php-amqplib). For example via Composer
{
"require": {
"videlalvaro/php-amqplib": "2.5.*"
}
}
Example
require_once('/vendor/autoload.php');
require_once('/php/br.rabbitMQ.php');
$rmq = new BrRabbitMQ(array('host' => 'localhost', 'port' => 5672));
$rmq->createExchange('exchange', 'topic');
$rmq->sendMessage('exchange', 'test', 'insert.task');
constructoraccept array with following settings: host, port, login, password, vhostcreateExchange(exchangeName, routingType)sendMessage(exchangeName, data, topic)