| 1 |
|
| 2 | const AmqpStats = require('amqp-stats')
|
| 3 | const jackrabbit = require('jackrabbit')
|
| 4 | const RabbitConfig = require('./rabbit-config')
|
| 5 |
|
| 6 | module.exports = function rabbitFn(settings) {
|
| 7 |
|
| 8 | // Build up config object
|
| 9 | const config = RabbitConfig(settings)
|
| 10 |
|
| 11 | // Initialize libraries
|
| 12 | const rabbit = jackrabbit(config.jackrabbitConnection, config.jackrabbitSsl)
|
| 13 | const exchange = rabbit.default()
|
| 14 | const stats = new AmqpStats(config.amqpStats)
|
| 15 |
|
| 16 | return {
|
| 17 | rabbit,
|
| 18 | exchange,
|
| 19 | stats,
|
| 20 | }
|
| 21 | }
|