broker-manager.js

const BrokerManager = function BrokerManager () {
  let connection = null
  let channel = null
  return Object.create({
    async getConnection () {
      if (!connection) {}
      return connection
    },
    async getChannel () {
      if (!channel) {}
      return channel
    }
  })
}

module.exports = BrokerManager

queue-manager.js

const QueueManager = function QueueManager ($tag = 'default', $broker = null) {
  let tag = $tag
  let broker = $broker
  let channel = null
  return Object.create({
    async start () {
      channel = await broker.getChannel()
      await channel.assertQueue(tag, { durable: true })
    }
  }) 
}

module.exports = QueueManager