code: function(config) {
    
      //console.log('RtcConnector: createMqttClient: server:  '+ config.server);
  
       var client = mqtt.connect(config.server + ':' + config.port);
       client.on('message', function(topic, message) {
         /*
          * This is called when a topic matching a valid subsription is received
          *   We have a valid subscription somewhere... 
          *   TODO:  This must call the filter FOR the topic and ensure it hasn't already
          *   been called.  
          */
         l('MESSAGE') && console.log('RtcConnector.mqttClient - Received Message on topic: '+topic);
          try {
            doFilter(topic,message);
          } catch(e) {
            console.error('MqttClient Message callback chain failure:',e);
            console.log(e.stack);
          }
        });
      client.on('connect', function(error) {
        console.log('RtcConnector: mqtt is CONNECTED');
        this.connected = true;
        this.emit('connected');
      }.bind(this));
      client.on('error', function(error) {
        console.log('RtcConnector: DISCONNECTED - error:'+ error);
        this.connected = false;
        this.emit('disconnected', error);
      }.bind(this));
      client.on('close', function(error) {
        console.log('RtcConnector: DISCONNECTED - close: '+error);
        this.connected = false;
        this.emit('disconnected',error);
      }.bind(this));
      return client;
    }
docs: createMqttClient - create MQTT client
  @private
  @param {Object} config