MQTT Processing Example

gistfile1.txt

import mqtt.*;

MQTTClient client;
String incomingData;

void setup() {
  client = new MQTTClient(this);
  client.connect("mqtt://10.35.30.35:1883");
  frameRate(1);
  size(500, 400); 
}

void draw() {
  background(0);
}

void clientConnected() {
  println("client connected");
  client.subscribe("#");
}

void messageReceived(String topic, byte[] payload) {
  println("new message: " + topic + " - " + new String(payload));
  incomingData = new String(payload);
  JSONObject json = parseJSONObject(incomingData);
  println(json);
  //int msg = json.getInt("values");
  //fill(255);
  //rect(10,200, 30, 380-msg);
  //println(msg);
}

void connectionLost() {
  println("connection lost");
}