public abstract class org.apache.nifi.registry.serialization.jackson.JacksonSerializer extends java.lang.Object implements org.apache.nifi.registry.serialization.VersionedSerializer
{
private static final org.slf4j.Logger logger;
private static final java.lang.String JSON_HEADER;
private static final java.lang.String DATA_MODEL_VERSION;
private final com.fasterxml.jackson.databind.ObjectMapper objectMapper;
public void <init>()
{
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.nifi.registry.serialization.jackson.JacksonSerializer v;
v := @this: org.apache.nifi.registry.serialization.jackson.JacksonSerializer;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <org.apache.nifi.registry.serialization.jackson.ObjectMapperProvider: com.fasterxml.jackson.databind.ObjectMapper getMapper()>();
v.<org.apache.nifi.registry.serialization.jackson.JacksonSerializer: com.fasterxml.jackson.databind.ObjectMapper objectMapper> = v;
return;
}
public void serialize(int, java.lang.Object, java.io.OutputStream) throws org.apache.nifi.registry.serialization.SerializationException
{
java.io.OutputStream v;
com.fasterxml.jackson.databind.ObjectWriter v;
org.apache.nifi.registry.serialization.SerializationException v;
com.fasterxml.jackson.databind.ObjectMapper v;
java.io.IOException v;
org.apache.nifi.registry.serialization.jackson.JacksonSerializer v;
org.apache.nifi.registry.serialization.jackson.SerializationContainer v;
java.lang.IllegalArgumentException v, v;
java.util.Map v;
int v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.nifi.registry.serialization.jackson.JacksonSerializer;
v := @parameter: int;
v := @parameter: java.lang.Object;
v := @parameter: java.io.OutputStream;
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("The object to serialize cannot be null");
throw v;
label:
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("OutputStream cannot be null");
throw v;
label:
v = new org.apache.nifi.registry.serialization.jackson.SerializationContainer;
specialinvoke v.<org.apache.nifi.registry.serialization.jackson.SerializationContainer: void <init>()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>("dataModelVersion", v);
virtualinvoke v.<org.apache.nifi.registry.serialization.jackson.SerializationContainer: void setHeader(java.util.Map)>(v);
virtualinvoke v.<org.apache.nifi.registry.serialization.jackson.SerializationContainer: void setContent(java.lang.Object)>(v);
label:
v = v.<org.apache.nifi.registry.serialization.jackson.JacksonSerializer: com.fasterxml.jackson.databind.ObjectMapper objectMapper>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.ObjectWriter writerWithDefaultPrettyPrinter()>();
virtualinvoke v.<com.fasterxml.jackson.databind.ObjectWriter: void writeValue(java.io.OutputStream,java.lang.Object)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.nifi.registry.serialization.SerializationException;
specialinvoke v.<org.apache.nifi.registry.serialization.SerializationException: void <init>(java.lang.String,java.lang.Throwable)>("Unable to serialize object", v);
throw v;
label:
return;
catch java.io.IOException from label to label with label;
}
public java.lang.Object deserialize(java.io.InputStream) throws org.apache.nifi.registry.serialization.SerializationException
{
org.apache.nifi.registry.serialization.SerializationException v;
com.fasterxml.jackson.databind.ObjectMapper v;
java.io.IOException v;
org.apache.nifi.registry.serialization.jackson.JacksonSerializer v;
java.lang.Object v, v;
com.fasterxml.jackson.core.type.TypeReference v;
java.io.InputStream v;
v := @this: org.apache.nifi.registry.serialization.jackson.JacksonSerializer;
v := @parameter: java.io.InputStream;
v = virtualinvoke v.<org.apache.nifi.registry.serialization.jackson.JacksonSerializer: com.fasterxml.jackson.core.type.TypeReference getDeserializeTypeRef()>();
label:
v = v.<org.apache.nifi.registry.serialization.jackson.JacksonSerializer: com.fasterxml.jackson.databind.ObjectMapper objectMapper>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.io.InputStream,com.fasterxml.jackson.core.type.TypeReference)>(v, v);
v = virtualinvoke v.<org.apache.nifi.registry.serialization.jackson.SerializationContainer: java.lang.Object getContent()>();
label:
return v;
label:
v := @caughtexception;
v = new org.apache.nifi.registry.serialization.SerializationException;
specialinvoke v.<org.apache.nifi.registry.serialization.SerializationException: void <init>(java.lang.String,java.lang.Throwable)>("Unable to deserialize object", v);
throw v;
catch java.io.IOException from label to label with label;
}
abstract com.fasterxml.jackson.core.type.TypeReference getDeserializeTypeRef() throws org.apache.nifi.registry.serialization.SerializationException;
public int readDataModelVersion(java.io.InputStream) throws org.apache.nifi.registry.serialization.SerializationException
{
byte[] v;
org.apache.nifi.registry.serialization.jackson.JacksonSerializer v;
java.lang.Integer v, v, v;
boolean v;
java.lang.Object[] v, v, v, v, v;
org.apache.nifi.registry.serialization.jackson.JacksonSerializer$1 v;
java.nio.charset.Charset v;
int v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v;
org.apache.nifi.registry.serialization.SerializationException v, v, v, v, v, v, v;
com.fasterxml.jackson.databind.ObjectMapper v;
java.io.IOException v, v;
java.lang.NumberFormatException v;
java.lang.Object v, v;
java.io.InputStream v;
v := @this: org.apache.nifi.registry.serialization.jackson.JacksonSerializer;
v := @parameter: java.io.InputStream;
v = newarray (byte)[1024];
label:
v = virtualinvoke v.<java.io.InputStream: int read(byte[])>(v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.nifi.registry.serialization.SerializationException;
v = virtualinvoke v.<java.io.IOException: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Could not read additional bytes to parse as serialization version 2 or later. \u0001");
specialinvoke v.<org.apache.nifi.registry.serialization.SerializationException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v = new java.lang.String;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
specialinvoke v.<java.lang.String: void <init>(byte[],int,int,java.nio.charset.Charset)>(v, 0, v, v);
v = virtualinvoke v.<java.lang.String: int indexOf(java.lang.String)>("\"header\"");
if v >= 0 goto label;
v = new org.apache.nifi.registry.serialization.SerializationException;
v = newarray (java.lang.Object)[2];
v[0] = "\"header\"";
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Could not find %s in the first %d bytes", v);
specialinvoke v.<org.apache.nifi.registry.serialization.SerializationException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<java.lang.String: int indexOf(java.lang.String,int)>("{", v);
if v >= 0 goto label;
v = new org.apache.nifi.registry.serialization.SerializationException;
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Could not find \'{\' starting header object in the first %d bytes.", v);
specialinvoke v.<org.apache.nifi.registry.serialization.SerializationException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<java.lang.String: int indexOf(java.lang.String,int)>("}", v);
if v >= 0 goto label;
v = new org.apache.nifi.registry.serialization.SerializationException;
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Could not find \'}\' ending header object in the first %d bytes.", v);
specialinvoke v.<org.apache.nifi.registry.serialization.SerializationException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v + 1;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(v, v);
v = <org.apache.nifi.registry.serialization.jackson.JacksonSerializer: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("headerObjectStr={}", v);
label:
v = new org.apache.nifi.registry.serialization.jackson.JacksonSerializer$1;
specialinvoke v.<org.apache.nifi.registry.serialization.jackson.JacksonSerializer$1: void <init>(org.apache.nifi.registry.serialization.jackson.JacksonSerializer)>(v);
v = v.<org.apache.nifi.registry.serialization.jackson.JacksonSerializer: com.fasterxml.jackson.databind.ObjectMapper objectMapper>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.lang.String,com.fasterxml.jackson.core.type.TypeReference)>(v, v);
v = virtualinvoke v.<java.util.HashMap: boolean containsKey(java.lang.Object)>("dataModelVersion");
if v != 0 goto label;
v = new org.apache.nifi.registry.serialization.SerializationException;
specialinvoke v.<org.apache.nifi.registry.serialization.SerializationException: void <init>(java.lang.String)>("Missing dataModelVersion");
throw v;
label:
v = virtualinvoke v.<java.util.HashMap: java.lang.Object get(java.lang.Object)>("dataModelVersion");
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
label:
return v;
label:
v := @caughtexception;
v = new org.apache.nifi.registry.serialization.SerializationException;
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Failed to parse header string \'%s\' due to %s", v);
specialinvoke v.<org.apache.nifi.registry.serialization.SerializationException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v := @caughtexception;
v = new org.apache.nifi.registry.serialization.SerializationException;
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<java.lang.NumberFormatException: java.lang.String getMessage()>();
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Failed to parse version string due to %s", v);
specialinvoke v.<org.apache.nifi.registry.serialization.SerializationException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.lang.NumberFormatException from label to label with label;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/nifi/registry/serialization/jackson/JacksonSerializer;");
<org.apache.nifi.registry.serialization.jackson.JacksonSerializer: org.slf4j.Logger logger> = v;
return;
}
}