         when message_types.ping
           @monitor.recordPing()
         when message_types.confirmation
-          @consumer.subscriptions.notify(identifier, "connected")
+          @subscriptions.notify(identifier, "connected")
         when message_types.rejection
-          @consumer.subscriptions.reject(identifier)
+          @subscriptions.reject(identifier)
         else
-          @consumer.subscriptions.notify(identifier, "received", message)
+          @subscriptions.notify(identifier, "received", message)
 
     open: ->
       ActionCable.log("WebSocket onopen event")
       @disconnected = false
-      @consumer.subscriptions.reload()
+      @subscriptions.reload()
 
     close: ->
       ActionCable.log("WebSocket onclose event")

  @reopenDelay: 500

  constructor: (@consumer) ->
    @monitor = new ActionCable.ConnectionMonitor this

  send: (data) ->

  disconnect: ->
    return if @disconnected
    @disconnected = true
    @subscriptions.notifyAll("disconnected")
    @monitor.recordDisconnect()
