project_test_001

dependencies {
    implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.5'
    implementation 'org.eclipse.paho:org.eclipse.paho.android.service:1.1.1'
}


String brokerUrl = "tcp://192.168.1.102:1883";
String clientId = MqttClient.generateClientId();
MqttAndroidClient mqttClient = new MqttAndroidClient(context, brokerUrl, clientId);


IMqttToken token = mqttClient.connect();
token.waitForCompletion();

Handler handler = new Handler();
Runnable runnable = new Runnable() {
    @Override
    public void run() {
        
        String topic = "test";
        String message = "vale ta data pu pernun oi sensors";
        try {
            MqttMessage mqttMessage = new MqttMessage(message.getBytes());
            mqttClient.publish(topic, mqttMessage);
        } catch (MqttException e) {
            e.printStackTrace();
        }
        handler.postDelayed(this, 1000); 
    }
};
handler.post(runnable);