Catch exception in MQTTAdapterListener.messageArrived()

This commit is contained in:
Lasantha Dharmakeerthi 2024-09-24 13:48:27 +00:00
commit 4424557413

View File

@ -243,6 +243,8 @@ public class MQTTAdapterListener implements MqttCallback, Runnable {
} else {
inputEventAdapterListener.onEvent(msgText);
}
} catch (Exception ex) {
log.error("Error in message arrive : ", ex);
} finally {
PrivilegedCarbonContext.endTenantFlow();
}