Add exception object to MappingFailedEvent
@@ -2,6 +2,7 @@ package io.siddhi.core.util.restream.model;
public class MappingFailedEvent {
private Object event;
+ private Exception exception;
private String cause;
public MappingFailedEvent(Object event, String cause) {
@@ -9,6 +10,12 @@ public class MappingFailedEvent {
this.cause = cause;
}
+ public MappingFailedEvent(Object event, Exception exception, String cause) {
+ this.event = event;
+ this.exception = exception;
+ this.cause = cause;
+ }
+
public Object getEvent() {
return event;
}
@@ -16,4 +23,8 @@ public class MappingFailedEvent {
public String getCause() {
return cause;
}
+
+ public Exception getException() {
+ return exception;
+ }
}
