diff --git a/components/extensions/siddhi-extensions/org.wso2.extension.siddhi.device/src/main/java/org/wso2/extension/siddhi/device/AddNotificationFunctionProcessor.java b/components/extensions/siddhi-extensions/org.wso2.extension.siddhi.device/src/main/java/org/wso2/extension/siddhi/device/AddNotificationFunctionProcessor.java index cc48643b8..ec9cfd347 100644 --- a/components/extensions/siddhi-extensions/org.wso2.extension.siddhi.device/src/main/java/org/wso2/extension/siddhi/device/AddNotificationFunctionProcessor.java +++ b/components/extensions/siddhi-extensions/org.wso2.extension.siddhi.device/src/main/java/org/wso2/extension/siddhi/device/AddNotificationFunctionProcessor.java @@ -106,7 +106,10 @@ public class AddNotificationFunctionProcessor extends StreamFunctionProcessor { try { isNotified = notificationManagementService.addNotification(new DeviceIdentifier(deviceId, deviceType), notification); } catch (NotificationManagementException e) { - log.error("Error occurred while adding notification for " + deviceType + " device with id " + deviceId, e); + // We are not throwing this exception to siddhi runtime as it will break the complete siddhi execution + // flow for the event stream coming in. + log.error("Error occurred while adding notification '" + notification.toString() + "' for " + + deviceType + " device with id " + deviceId, e); } return new Object[]{isNotified};