             authQueue.subscribe (message, headers, deliveryInfo)=>
               {routingKey, correlationId} = deliveryInfo
               socketId = correlationId
+              messageStr = "#{message.data}"
               messageData = (try JSON.parse messageStr) or message
               switch routingKey
                 when 'kite.join'


    joinClient =(messageData, socketId)->
      {channel, routingKey, serviceType} = messageData
      switch serviceType
        when 'bongo', 'kite'
          joinClientHelper.call this, messageData, routingKey, socketId

    clientsByExchange.push client

  rejectClient:(routingKey, message)->
    return console.trace()  unless routingKey?
    @bongo.respondToClient routingKey, {
      method    : 'error'
      arguments : [message: message ? 'Access denied']
