| 1 | winston = require 'winston'
|
| 2 | FreddySetup = require './freddy/freddy_setup'
|
| 3 |
|
| 4 | defaultLogger = new winston.Logger
|
| 5 | transports: [ new winston.transports.Console level: 'info', colorize: true, timestamp: true ]
|
| 6 |
|
| 7 | setup = null
|
| 8 | connect = (amqpUrl, logger = defaultLogger) ->
|
| 9 | setup = new FreddySetup(logger)
|
| 10 | setup.connect(amqpUrl)
|
| 11 |
|
| 12 | addErrorListener = (listener) ->
|
| 13 | setup.addErrorListener listener if setup
|
| 14 |
|
| 15 | exports.connect = connect
|
| 16 | exports.addErrorListener = addErrorListener
|