amqper
Advanced tools
Comparing version 0.1.3 to 0.1.4
{ | ||
"name": "amqper", | ||
"version": "0.1.3", | ||
"version": "0.1.4", | ||
"description": "A simple and elegant AMQP client for node based on amqplib.", | ||
@@ -5,0 +5,0 @@ "homepage": "https://github.com/taoyuan/amqper", |
# amqper | ||
[![NPM version][npm-image]][npm-url] | ||
@@ -8,3 +9,2 @@ [![Build Status][circleci-image]][circleci-url] | ||
## Install | ||
@@ -16,7 +16,39 @@ | ||
## Usage | ||
__Coming Soon__ | ||
### round-robin | ||
Run multiple consumer.js for round-robin shared. | ||
__consumer.js__ | ||
```js | ||
var amqper = require('amqper'); | ||
var client = amqper.connect('amqp://guest:guest@localhost:5672'); | ||
client.$promise.then(function () { | ||
console.log('ready'); | ||
client.route('test.a', function (message) { | ||
console.log(message.payload); | ||
}); | ||
}); | ||
``` | ||
__producer.js__ | ||
```js | ||
var amqper = require('amqper'); | ||
var client = amqper.connect('amqp://guest:guest@localhost:5672'); | ||
client.$promise.then(function () { | ||
for (var i = 0; i < 10; i++) { | ||
client.publish('amq.topic', 'test.a', i); | ||
} | ||
}); | ||
``` | ||
## License | ||
@@ -23,0 +55,0 @@ |
14127
17
322
63