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

    @stack = []
    @services = {}

    @connection = amqp.createConnection @mqConfig
    @connection.setMaxListeners(0)
    @readyState = 0
    @connection.once 'ready', => @readyState = 1


    #@initBlacklist options.blacklist


    {exchangeName} = @mqConfig

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