serviser-rabbitmq
v0.2.1
Published
Integrates AMQP 0.9.1 with serviser
Downloads
1
Readme
Implementation of serviser's AppInterface
which allows to define receiving endpoints of AMQP 0.9.1
in the same manner http(s)
routes would be defined.
Uses forked rabbit.js library under the hood.
Usage
Load the plugin at the bottom of your index.js
file:
require('serviser-rabbitmq'); //loads the plugin
Initialize a message queue App in your app.js file:
service.buildMQApp('your-app-name-in-config.json5');
Example of SUBSCRIBE
endpoint definition of PUBLISH & SUBSCRIBE
pattern:
const router = service.appManager
.get('your-app-name-in-config.json5')
.buildRouter({
version: 1,
url: '.'
});
router.buildRoute({
url: 'email-updated',
type: 'subscribe', // one of: subscribe|pull|reply|worker
summary: 'Sync user email',
amqp: {/*amqp specific options*/},
sdkMethodName: 'email-updated'
}).main(function(req) {
return User.update({email: req.body.email});
});
PUBLISH
data on client side:
//serviser based project...
const rabbit = require('serviser-rabbit');
const remoteServiceMgr = service.getRemoteServiceManager();
const resourceManager = service.resourceManager;
const amqp = rabbit.createConnection('amqp://username:password@localhost:5672/vhost');
resourceManager.register('amqp', amqp);
const sdk = remoteServiceMgr.buildRemoteService('user:<your-app-name>:v1.0', {socket: amqp});
const socket = sdk.get('email-updated');
socket.write('[email protected]');
Route type
s
as described under socket types section of rabbit.js
documentation.
Tests
> export AMQP_URI='amqp://username:password@localhost:5672/vhost'
> npm test