src-java/base-topology/base-messaging/src/main/java/org/openkilda/messaging/error/DeserializationErrorMessage.java
/**
     * Create {@link DeserializationErrorMessage} instance using data from deserialization exception.
     */
Create  DeserializationErrorMessage instance using data from deserialization exception.
Create DeserializationErrorMessage instance using data from deserialization exception .
public static DeserializationErrorMessage createFromException(
            String topic, Class<?> baseClass, String rawData, Exception error) {
        String errorMessage = String.format(
                "Failed to deserialize message in kafka-topic \"%s\" using base class %s: %s",
                topic, baseClass.getName(), error.getMessage());
        return new DeserializationErrorMessage(
                new ErrorData(ErrorType.INTERNAL_ERROR, errorMessage, rawData),
                System.currentTimeMillis(), UUID.randomUUID().toString());
    }
public static DeserializationErrorMessage createFromException ( String topic , Class < ? > baseClass , String rawData , Exception error ) { String errorMessage = String . format ( "Failed to deserialize message in kafka-topic \"%s\" using base class %s: %s" , topic , baseClass . getName ( ) , error . getMessage ( ) ) ; return new DeserializationErrorMessage ( new ErrorData ( ErrorType . INTERNAL_ERROR , errorMessage , rawData ) , System . currentTimeMillis ( ) , UUID . randomUUID ( ) . toString ( ) ) ; }
Create {@link DeserializationErrorMessage} instance using data from deserialization exception.
Create { @link DeserializationErrorMessage } instance using data from deserialization exception .