       exchange.publish "", message, type: "dispatcher_notify_user"
       exchange.close()
 
-    @connection.on 'error', @emit.bind this, 'error'
 
   parseRoutingKey: do ->
     getEdgeMeaning = (i)->

    @updateInstancesMessageThrottleMs = 100

  initMQ: ->
    @connection = amqp.createConnection @mqConfig, reconnect: yes
    @connection.setMaxListeners(0)
    @readyState = 0
    @connection.once 'ready', => @readyState = 1

    @stack = []
    @services = {}

    # TODO comment out this when we completely remove broker
    #@initMQ()

    #@initBlacklist options.blacklist

