1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31
| on.setOnClickListener(new View.OnClickListener() {
public void onClick(View v) {
for(int i=0;i<topicStr.length;i++) {
String [] topic = topicStr;
String message = "ON";
try {
client.publish(String.valueOf(topic), message.getBytes(), 0, false);
} catch (MqttException e) {
e.printStackTrace();
}
;
client.setCallback(new MqttCallback() {
@Override
public void connectionLost(Throwable cause) {
}
@Override
public void messageArrived(String topic, MqttMessage message) throws Exception {
subText.setText(new String(message.getPayload()));
vibrator.vibrate(500);
}
@Override
public void deliveryComplete(IMqttDeliveryToken token) {
}
});
}
}}); |
Partager