package mqtt;

import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.MqttPersistenceException;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;

public class MqttPublishSample {
	static int qos = 2;

	public static void main(String[] args) {

	    String topic        = "sensor/temp";
	    String broker       = "tcp://10.129.144.26:1883";
	    String clientId     = "sensortemp1";


	    MemoryPersistence persistence = new MemoryPersistence();

	    try {
	        MqttClient sampleClient = new MqttClient(broker, clientId, persistence);
	        MqttConnectOptions connOpts = new MqttConnectOptions();
	        connOpts.setCleanSession(true);
	        System.out.println("Connecting to broker: "+broker);
	        sampleClient.connect(connOpts);
	        System.out.println("Connected");

	        enviaTemperatura(sampleClient, topic);

	    } catch(MqttException me) {
	        System.out.println("reason "+me.getReasonCode());
	        System.out.println("msg "+me.getMessage());
	        System.out.println("loc "+me.getLocalizedMessage());
	        System.out.println("cause "+me.getCause());
	        System.out.println("excep "+me);
	        me.printStackTrace();
	    } catch (InterruptedException e) {
			e.printStackTrace();
		}
	}



	public static void enviaTemperatura(MqttClient sampleClient, String topic) throws MqttPersistenceException, MqttException, InterruptedException {

		while(true) {
			double temperatura = (Math.random() * ((35 - 25) + 1)) + 25;
			System.out.println("Publishing message: "+temperatura);
			MqttMessage message = new MqttMessage(Double.toString(temperatura).getBytes());
			message.setQos(qos);
			sampleClient.publish(topic, message);
	        System.out.println("Message published");
	        Thread.sleep(5000);

		}

	}


}