code: function initiateSubscribe(clientObj) {
    this.__channels = {};
    var self = this;
    clientObj.subscribe('internalPing');
    clientObj.on('message', function(channelName, message) {
      if (channelName === 'internalPing') return;  // this is our internal channel for ping
      if (typeof self.__channels[channelName] === 'undefined') return; // we have no channel.
      try {
        var data = JSON.parse(message);
      } catch (e) {
        data = message;
      }
      for (var i = 0; i < self.__channels[channelName].length; i++) {
        self.__channels[channelName][i](data);
      }
    });
  }
docs: /*
  Initiates the subscription mechanism and starts listening to messages.