leopoldos

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.100:1883"; // replace with your broker URL
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() {
        // generate a random number between 0 and 100
        int randomNumber = (int) (Math.random() * 100);
        String topic = "my/topic";
        String message = Integer.toString(randomNumber);
        try {
            MqttMessage mqttMessage = new MqttMessage(message.getBytes());
            mqttClient.publish(topic, mqttMessage);
        } catch (MqttException e) {
            e.printStackTrace();
        }
        handler.postDelayed(this, 1000); // send a message every second
    }
};
handler.post(runnable); // start sending messages