     @stack = []
     @services = {}
 
-    @connection = amqp.createConnection @mqConfig
-    @connection.setMaxListeners(0)
-    @readyState = 0
-    @connection.once 'ready', => @readyState = 1
-
+    # TODO comment out this when we completely remove broker
+    #@initMQ()
 
     #@initBlacklist options.blacklist
 

    @updateInstancesMessageThrottleMs = 100

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

      exchange.publish "", message, type: "dispatcher_notify_user"
      exchange.close()


  parseRoutingKey: do ->
    getEdgeMeaning = (i)->
