node package manager
It’s your turn. Help us improve JavaScript. Take the 2017 JavaScript Ecosystem Survey »

engined-amqp

engined-amqp

AMQP agent service for engined, which is based on amqplib.

NPM

Installation

Install via NPM:

npm install engined-amqp

Usage

You must start AMQP agent service in engined, see example below:

const { Manager } = require('engined');
const AMQPService = require('engined-amqp');
 
const main = async () => {
 
    // Create manager 
    let serviceManager = new Manager({ verbose: true });
 
    // Adding agent to manager 
    serviceManager.add('AMQP', AMQPService);
 
    // Start all services 
    await serviceManager.startAll();
};
 
main();

APIs for managing AMQP agent are registered after starting service. Now you can create a AMQP agent to connect to server for your propose by using provided APIs.

 
// Create a new agent named "myAMQP" 
let agent = this.getContext('AMQP').createAgent('myAMQP');
 
// Connect with AMQP URI 
let await agent.connect('amqp://localhost/myvhost');
 
// Get channel for AMQP connection 
let channel = agent.getChannel();
 
// channel is provided by amqplib ... 

License

Licensed under the MIT License

Authors

Copyright(c) 2017 Fred Chien(錢逢祥) <cfsghost@gmail.com>