|
|
@ -84,8 +84,10 @@ public class MQTTEventAdapter implements InputEventAdapter {
|
|
|
|
.equals(MultitenantConstants.SUPER_TENANT_DOMAIN_NAME)) {
|
|
|
|
.equals(MultitenantConstants.SUPER_TENANT_DOMAIN_NAME)) {
|
|
|
|
return;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (!mqttAdapterListener.isConnectionInitialized()) {
|
|
|
|
synchronized (this.mqttAdapterListener) {
|
|
|
|
mqttAdapterListener.createConnection();
|
|
|
|
if (!mqttAdapterListener.isConnectionInitialized()) {
|
|
|
|
|
|
|
|
mqttAdapterListener.createConnection();
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -102,8 +104,10 @@ public class MQTTEventAdapter implements InputEventAdapter {
|
|
|
|
if (ServerStatus.getCurrentStatus().equals(ServerStatus.STATUS_SHUTTING_DOWN)) {
|
|
|
|
if (ServerStatus.getCurrentStatus().equals(ServerStatus.STATUS_SHUTTING_DOWN)) {
|
|
|
|
Thread thread = new Thread(new Runnable() {
|
|
|
|
Thread thread = new Thread(new Runnable() {
|
|
|
|
public void run() {
|
|
|
|
public void run() {
|
|
|
|
if (mqttAdapterListener != null) {
|
|
|
|
synchronized (mqttAdapterListener) {
|
|
|
|
mqttAdapterListener.stopListener(eventAdapterConfiguration.getName());
|
|
|
|
if (mqttAdapterListener != null) {
|
|
|
|
|
|
|
|
mqttAdapterListener.stopListener(eventAdapterConfiguration.getName());
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
});
|
|
|
|
});
|
|
|
|