         return if data.enabled == 'false'
         @set('eventSource', new EventSource(data.url))
         Ember.$(window).unload => @stop()
+        @set('eventNames', data.eventNames)
         data.eventNames.forEach (eventName) =>
           @addEventListener(eventName)
+        @play()
     Ember.$.ajax(params)
 
-  msgResponse: (msg) ->
-    esData = JSON.parse(msg.data)
+  msgResponse: (esData) ->
     action = esData.action
     meta = esData.meta
     delete esData.meta

      phase.get('tasks').addObject(task)
    if action == 'updated' && phase != oldPhase
      phase.get('tasks').addObject(task)
      oldPhase.get('tasks').removeObject(oldTask)
      task.set('phase', phase)

    task.triggerLater('didLoad')

interval = 500
ETahi.EventStream = Em.Object.extend
  eventSource: null
  eventNames: null
  messageQueue: null
  wait: false
  init: ->
