   Serial.println("DEBUG :: Sending temp ");
   Serial.println(temp);
   //"io.m2m/arduino/lightsensor"
-  client.publish("arduino-weather-exchange", "temp");
-}
-
+  
+  //Format for the message to the following SensorId,temperature,humidity
+  client.publish("arduino-weather-queue", "Sensor3,17.0,16.3");//getSensorId());// + "," + temp + "," + humidity);
+}
+
+String getSensorId() {
+  return "need-a-sensor-id";
+}
 
 void printWifiData() {
   // print your WiFi shield's IP address:


// handles message arrived on subscribed topic(s)
void callback(char* topic, byte* payload, unsigned int length) {

//  int i = 0;
//
//  //Serial.println("Message arrived:  topic: " + String(topic));
//  //Serial.println("Length: " + String(length,DEC));
//
//  // create character buffer with ending null terminator (string)
//  for (i = 0; i < length; i++) {
//    message_buff[i] = payload[i];
//  }
//  message_buff[i] = '\0';
//
//  String msgString = String(message_buff);
//
//  //Serial.println("Payload: " + msgString);
//
//  if (msgString.equals("{\"command\":{\"lightmode\": \"OFF\"}}")) {
//    senseMode = MODE_OFF;
//  } else if (msgString.equals("{\"command\":{\"lightmode\": \"ON\"}}")) {
//    senseMode = MODE_ON;
//  } else if (msgString.equals("{\"command\":{\"lightmode\": \"SENSE\"}}")) {
//    senseMode = MODE_SENSE;
//  }
}


//setup MQTT
WiFiClient wifiClient;
//MQTT
PubSubClient client(serverRabbit, port, callback, wifiClient);
  
void setup() {
  // initialize serial and wait for the port to open:
