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

    {exchangeName} = @mqConfig

    # TODO exchange version must be innjected here, when we have that support
    @connection.exchange "#{exchangeName}:0", EXCHANGE_OPTIONS, (exchange) =>
      {eventName, body, account} = data
      message = {
        account

    @stack = []
    @services = {}

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

    #@initBlacklist options.blacklist

