return;
}
lastServerTimeDeltaEstimate = rxtime - mtime;
- setMSE(MqttServerEvent.MSE_SUB);
+ notifyMSE();
}
});
Log.d("Service", "domqtt disconn close mqtt", me);
}
mMqc.unregisterResources();
-
+ mMqc = null;
} else {
Log.d("Service", "domqtt no client");
}
// If disconnecting is all we were told to do, we're done.
if (server == null) {
- mMqc = null;
return;
}
void onHandbookFetch(LocalBinder b);
}
private final Set<Observer> mObsvs = new HashSet<>();
+ private void notifyMSE() {
+ synchronized(this) {
+ for (Observer o : mObsvs) { o.onMqttServerEvent(mBinder, mMSE); }
+ }
+ }
private void setMSE(MqttServerEvent mse) {
synchronized(this) {
mMSE = mse;
- for (Observer o : mObsvs) { o.onMqttServerEvent(mBinder, mse); }
+ notifyMSE();
}
}
private void notifyServerChanged(String sURL) {