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();

 
// 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 ...