!7

lib 1400324 // Eclipse Paho (MQTT)

import org.eclipse.paho.client.mqttv3.*;

cmodule MQTTSubscriberSpike > DynPrintLog {
  S topic = "iot_data";
  
  start-thread {
    MqttClient client = new("tcp://localhost:1883", MqttClient.generateClientId());
    client.setCallback(new MyCallback);
    client.connect();
    client.subscribe(topic);
  }
  
  class MyCallback implements MqttCallback {
    public void connectionLost(Throwable throwable) {
      print("Connection to MQTT broker lost!");
    }

    public void messageArrived(S s, MqttMessage mqttMessage) {
      print("Message received: "+ fromUtf8(mqttMessage.getPayload()));
    }

    public void deliveryComplete(IMqttDeliveryToken token) {
      print("Delivery complete: " + token);
    }
  }
}