|
@@ -173,7 +173,7 @@ public class MqttService implements DriverService {
|
|
@Override
|
|
@Override
|
|
public void onSuccess(IMqttToken asyncActionToken) {
|
|
public void onSuccess(IMqttToken asyncActionToken) {
|
|
try {
|
|
try {
|
|
- mqttClient.subscribe(destination.getTopic(), 0);
|
|
|
|
|
|
+ mqttClient.subscribe(destination.getTopic(), 2);
|
|
} catch (MqttException e) {
|
|
} catch (MqttException e) {
|
|
throw new RuntimeException(e);
|
|
throw new RuntimeException(e);
|
|
}
|
|
}
|