package br.usp.nds.remote.persistencia;

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

public class Mqtt extends Entidade {

	private String payload;
	
	public void publicar() throws MqttException {
		MqttClient client = new MqttClient("tcp://nds.lme.usp.br:1883", "remote", new MemoryPersistence());
		client.connect();
		client.publish("remote", new MqttMessage(payload.getBytes()));
		client.disconnect();
	}

	public String getPayload() {
		return payload;
	}

	public void setPayload(String payload) {
		this.payload = payload;
	}
}