 
   handleBrokerSubscribed:->
 
-
   cycleChannel: ->
     @setStopPinging()
     @channel.off()

      callbacks   : {}
    @channel.once 'pong', callback  if callback

  setStartPinging: -> @stopPinging = false

  setStopPinging: -> @stopPinging = true

  handleMessageArrived: ->
    clearTimeout @unresponsiveTimeoutId

    @channel.exchange = resourceName
    @emit 'ready'

  handleError: (err) -> console.error err

  handlePong: ->
    @channel.emit 'pong'
