config.js
'use strict';

const queueTest = process.env.AMQ_TEST_CONSUME_PRIVATE || 'fb.test.consume.private';
const rabbitMqProtocol = process.env.AMQ_PROTOCOL || 'amqp';
const rabbitMqUser = process.env.AMQ_USER || false;
const rabbitMqPassword = process.env.AMQ_PASSWORD || false;
const rabbitMqServers = process.env.AMQ_SERVERS || '';

const connections = rabbitMqServers.split(';').map(server => ${rabbitMqProtocol}://${rabbitMqUser}:${rabbitMqPassword}@${server}:5672//?heartbeat=10);

const exchanges = {};

exchanges[queueTest] = {
type: 'direct',
};

module.exports = {
vhosts: {
' / ': {
connection: {
retry: {
min: 1000,
max: 60000,
factor: 2,
strategy: 'exponential',
},
},
connectionStrategy: 'random',
connections,
exchanges,
queues: [
queueTest,
],
bindings: {
bindingTest: {
source: queueTest,
destination: queueTest,
destinationType: 'queue',
bindingKey: 'private_key',
},
},
publications: {
demoPublish: {
exchange: queueTest,
routingKey: 'private_key',
},
},
subscriptions: {
demoConsume: {
queue: queueTest,
},
},
},
},
};