public class ErrorHandlerUtils extends Object
Modifier and Type | Method and Description |
---|---|
static String |
constructAddErrorRecordString(ComplexEventChunk<StreamEvent> eventChunk,
boolean isObjectColumnPresent,
io.siddhi.query.api.definition.TableDefinition tableDefinition,
Exception e) |
static String |
constructErrorRecordString(ComplexEventChunk<StateEvent> eventChunk,
boolean isObjectColumnPresent,
io.siddhi.query.api.definition.TableDefinition tableDefinition,
Exception e) |
static byte[] |
getAsBytes(Object event) |
static Object |
getAsObject(byte[] byteArray) |
static String |
getOriginalPayloadString(Object originalPayloadAsObject) |
static byte[] |
getThrowableStackTraceAsBytes(Throwable throwable) |
public static byte[] getAsBytes(Object event) throws IOException
IOException
public static Object getAsObject(byte[] byteArray) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public static byte[] getThrowableStackTraceAsBytes(Throwable throwable) throws IOException
IOException
public static String getOriginalPayloadString(Object originalPayloadAsObject)
public static String constructAddErrorRecordString(ComplexEventChunk<StreamEvent> eventChunk, boolean isObjectColumnPresent, io.siddhi.query.api.definition.TableDefinition tableDefinition, Exception e)
public static String constructErrorRecordString(ComplexEventChunk<StateEvent> eventChunk, boolean isObjectColumnPresent, io.siddhi.query.api.definition.TableDefinition tableDefinition, Exception e)
Copyright © 2021. All rights reserved.