70com/dexels/replication/impl/json/ReplicationJSONjava/lang/ObjectloggerLorg/slf4j/Logger; objectMapper-Lcom/fasterxml/jackson/databind/ObjectMapper;()VCode org/slf4j/LoggerFactory  getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;  +com/fasterxml/jackson/databind/ObjectMapper     LineNumberTableLocalVariableTable this2Lcom/dexels/replication/impl/json/ReplicationJSON;parseReplicationMessaget([BLjava/util/Optional;Lcom/fasterxml/jackson/databind/ObjectMapper;)Lcom/dexels/replication/api/ReplicationMessage; Exceptions$2com/fasterxml/jackson/core/JsonProcessingException&java/io/IOException Signature([BLjava/util/Optional;Lcom/fasterxml/jackson/databind/ObjectMapper;)Lcom/dexels/replication/api/ReplicationMessage; * +, parseJSONZ([BLcom/fasterxml/jackson/databind/ObjectMapper;)Lcom/fasterxml/jackson/databind/JsonNode;..com/fasterxml/jackson/databind/node/ObjectNode 0 +1u(Ljava/util/Optional;Lcom/fasterxml/jackson/databind/node/ObjectNode;)Lcom/dexels/replication/api/ReplicationMessage;data[BsourceLjava/util/Optional;LocalVariableTypeTable(Ljava/util/Optional;(Ljava/io/InputStream;Ljava/util/Optional;Lcom/fasterxml/jackson/databind/ObjectMapper;)Lcom/dexels/replication/api/ReplicationMessage;(Ljava/io/InputStream;Ljava/util/Optional;Lcom/fasterxml/jackson/databind/ObjectMapper;)Lcom/dexels/replication/api/ReplicationMessage; ; +<m(Ljava/io/InputStream;Lcom/fasterxml/jackson/databind/ObjectMapper;)Lcom/fasterxml/jackson/databind/JsonNode;streamLjava/io/InputStream;jsonSerializer4(Lcom/dexels/replication/api/ReplicationMessage;Z)[B B ?C5(Lcom/dexels/replication/api/ReplicationMessage;ZZ)[Bmsg/Lcom/dexels/replication/api/ReplicationMessage;includeNullValuesZ IKJ-com/dexels/replication/api/ReplicationMessage LMusePrettyPrint()Z O PQwriterWithDefaultPrettyPrinter/()Lcom/fasterxml/jackson/databind/ObjectWriter; S TQwriterVjava/io/ByteArrayOutputStream U IY Z[ combinedKey()Ljava/lang/String; ]_^java/lang/String `agetBytes()[B Uc dewrite([B)V Ug dh(I)V j kltoJSONb(Lcom/dexels/replication/api/ReplicationMessage;Z)Lcom/fasterxml/jackson/databind/node/ObjectNode; npo+com/fasterxml/jackson/databind/ObjectWriter qr writeValue+(Ljava/io/OutputStream;Ljava/lang/Object;)V Ut ua toByteArraywIJSON parsing failing with key: {} value: {} types: {} submessagenames: {} Iy z[queueKey I| }~values()Ljava/util/Map; I ~types I ~ subMessageMap  java/util/Map keySet()Ljava/util/Set; org/slf4j/Logger error((Ljava/lang/String;[Ljava/lang/Object;)V"Error serializing, got json error: *(Ljava/lang/String;Ljava/lang/Throwable;)V # getCause()Ljava/lang/Throwable;Error serializing cause: # printStackTraceJSON failed to write: {} - [toString '(Ljava/lang/String;Ljava/lang/Object;)V{} ] (Ljava/lang/String;)Vjava/lang/RuntimeExceptionWeird json problem java/lang/ThrowabledumpKeyw-Lcom/fasterxml/jackson/databind/ObjectWriter;baosLjava/io/ByteArrayOutputStream;e4Lcom/fasterxml/jackson/core/JsonProcessingException;Ljava/io/IOException; StackMapTable jsonDescriberx(Lcom/dexels/replication/api/ReplicationMessage;Lcom/dexels/replication/api/ReplicationMessageParser;)Ljava/lang/String; java/util/Collections emptySet I  flatValueMap3(ZLjava/util/Set;Ljava/lang/String;)Ljava/util/Map; parser5Lcom/dexels/replication/api/ReplicationMessageParser;  readTree-([B)Lcom/fasterxml/jackson/databind/JsonNode;Exception on parsing json! {} ] e 9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)Vres)Lcom/fasterxml/jackson/databind/JsonNode;tLjava/lang/Throwable;  @(Ljava/io/InputStream;)Lcom/fasterxml/jackson/databind/JsonNode; resolveValue(Lcom/fasterxml/jackson/databind/ObjectMapper;Lcom/fasterxml/jackson/databind/node/ObjectNode;Ljava/lang/String;Ljava/lang/String;Ljava/lang/Object;Z)V - putNullD(Ljava/lang/String;)Lcom/fasterxml/jackson/databind/node/ObjectNode;java/lang/StringBuilderNull type for key: append-(Ljava/lang/String;)Ljava/lang/StringBuilder; info ] hashCode()Ibinary ] equals(Ljava/lang/Object;)Zdouble clocktimestringdateenumlist long boolean float coordinate binary_digestintegerValue - putV(Ljava/lang/String;Ljava/lang/String;)Lcom/fasterxml/jackson/databind/node/ObjectNode;java/lang/Integer - W(Ljava/lang/String;Ljava/lang/Integer;)Lcom/fasterxml/jackson/databind/node/ObjectNode; java/lang/Long -" #T(Ljava/lang/String;Ljava/lang/Long;)Lcom/fasterxml/jackson/databind/node/ObjectNode;%java/lang/Double -' (V(Ljava/lang/String;Ljava/lang/Double;)Lcom/fasterxml/jackson/databind/node/ObjectNode;*java/lang/Float -, -U(Ljava/lang/String;Ljava/lang/Float;)Lcom/fasterxml/jackson/databind/node/ObjectNode;/java/lang/Boolean -1 2W(Ljava/lang/String;Ljava/lang/Boolean;)Lcom/fasterxml/jackson/databind/node/ObjectNode;4java/text/SimpleDateFormat6yyyy-MM-dd HH:mm:ss.SS 39java/util/Date 3; <=format$(Ljava/util/Date;)Ljava/lang/String;?HH:mm:ss -A BCputArrayC(Ljava/lang/String;)Lcom/fasterxml/jackson/databind/node/ArrayNode;Ejava/util/List G HI valueToTree=(Ljava/lang/Object;)Lcom/fasterxml/jackson/databind/JsonNode;K-com/fasterxml/jackson/databind/node/ArrayNode JM NOaddAll`(Lcom/fasterxml/jackson/databind/node/ArrayNode;)Lcom/fasterxml/jackson/databind/node/ArrayNode; QSRjava/util/Base64 TU getEncoder()Ljava/util/Base64$Encoder;3 XZYjava/util/Base64$Encoder [\encodeToString([B)Ljava/lang/String;^3com/dexels/immutable/api/customtypes/CoordinateType ]a@Unknown type: {} while serializing replication message to JSON. c dwarnm0Lcom/fasterxml/jackson/databind/node/ObjectNode;keyLjava/lang/String;typevalueLjava/lang/Object;c arrayNode/Lcom/fasterxml/jackson/databind/node/ArrayNode;O(Ljava/lang/String;Lcom/fasterxml/jackson/databind/JsonNode;)Ljava/lang/Object;q,com/fasterxml/jackson/databind/node/NullNode sut'com/fasterxml/jackson/databind/JsonNode v[asText sx yasInt { |}valueOf(I)Ljava/lang/Integer; s asLong()J  |(J)Ljava/lang/Long; s asDouble()D $ |(D)Ljava/lang/Double; s M asBoolean . |(Z)Ljava/lang/Boolean; s MisNull Q  getDecoder()Ljava/util/Base64$Decoder; java/util/Base64$Decoder decode(Ljava/lang/String;)[Bjava/util/ArrayList  J iterator()Ljava/util/Iterator; java/util/Iterator next()Ljava/lang/Object; s MisInt D add s M isTextual3Unsupported array element type: {} in {}. Ignoring!  d  MhasNext 3 parse$(Ljava/lang/String;)Ljava/util/Date;%Cannot parse date {} = returning null*Cannot parse clocktime {} = returning null ]+Cannot parse coordinate {} = returning nullUnsupported type {}java/text/ParseExceptionjava/lang/ExceptionjsonNodenoderesultLjava/util/List;objNodeLjava/text/ParseException;Ljava/lang/Exception;$Ljava/util/List;  createObjectNode2()Lcom/fasterxml/jackson/databind/node/ObjectNode; I [ transactionId TransactionId Timestamp I  timestamp - E(Ljava/lang/String;J)Lcom/fasterxml/jackson/databind/node/ObjectNode; Operation I  operation;()Lcom/dexels/replication/api/ReplicationMessage$Operation; 7com/dexels/replication/api/ReplicationMessage$Operation  createArrayNode1()Lcom/fasterxml/jackson/databind/node/ArrayNode; I  primaryKeys()Ljava/util/List; D J C PrimaryKeys - setf(Ljava/lang/String;Lcom/fasterxml/jackson/databind/JsonNode;)Lcom/fasterxml/jackson/databind/JsonNode; I message-()Lcom/dexels/immutable/api/ImmutableMessage;  appendImmutable_(Lcom/fasterxml/jackson/databind/node/ObjectNode;Lcom/dexels/immutable/api/ImmutableMessage;Z)V %Error serializing replicationmessage   columns:  -(Ljava/lang/Object;)Ljava/lang/StringBuilder;instancekeys immutable+Lcom/dexels/immutable/api/ImmutableMessage;Columns )com/dexels/immutable/api/ImmutableMessage |  entrySet  java/util/Set java/util/Map$Entry " #getKey % &'get&(Ljava/lang/Object;)Ljava/lang/Object;)Type + ,getValue .  1 2~subMessageListMap4 SubMessage 6 78toJSONImmutable^(Lcom/dexels/immutable/api/ImmutableMessage;Z)Lcom/fasterxml/jackson/databind/node/ObjectNode; J: ;Z(Lcom/fasterxml/jackson/databind/JsonNode;)Lcom/fasterxml/jackson/databind/node/ArrayNode;columnsLjava/util/Map;Ljava/util/Map$Entry; subMessageentry arraynode5Ljava/util/Map;;Ljava/util/Map$Entry;TLjava/util/Map$Entry;fLjava/util/Map$Entry;>;=Ljava/util/List; J KLNONE9Lcom/dexels/replication/api/ReplicationMessage$Operation; N O[nameQ%Error serializing replicationmessage. (Ljava/util/Optional;Lcom/fasterxml/jackson/databind/node/ObjectNode;)Lcom/dexels/replication/api/ReplicationMessage; -U &V=(Ljava/lang/String;)Lcom/fasterxml/jackson/databind/JsonNode; ]X Y[ toUpperCase [ |\M(Ljava/lang/String;)Lcom/dexels/replication/api/ReplicationMessage$Operation; ^ _ emptyList a bcunmodifiableList"(Ljava/util/List;)Ljava/util/List; e fgparseImmutable](Lcom/fasterxml/jackson/databind/node/ObjectNode;)Lcom/dexels/immutable/api/ImmutableMessage;i ParamMessage kmljava/util/Optional noempty()Ljava/util/Optional; kq rs ofNullable((Ljava/lang/Object;)Ljava/util/Optional;u vwapply()Ljava/util/function/Function; ky z{map3(Ljava/util/function/Function;)Ljava/util/Optional; }~1com/dexels/replication/factory/ReplicationFactory createReplicationMessage(Ljava/util/Optional;Ljava/util/Optional;Ljava/util/Optional;Ljava/lang/String;JLcom/dexels/replication/api/ReplicationMessage$Operation;Ljava/util/List;Lcom/dexels/immutable/api/ImmutableMessage;Ljava/util/Optional;Ljava/util/Optional;)Lcom/dexels/replication/api/ReplicationMessage;Jl flatMessageparamMsg$Ljava/util/List;java/util/HashMap  - fields(Null type found in replication message: n writeValueAsString&(Ljava/lang/Object;)Ljava/lang/String;  Error:  o  8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;  unmodifiableMap (Ljava/util/Map;)Ljava/util/Map;java/util/LinkedList   ~emptyMap -com/dexels/immutable/factory/ImmutableFactory createi(Ljava/util/Map;Ljava/util/Map;Ljava/util/Map;Ljava/util/Map;)Lcom/dexels/immutable/api/ImmutableMessage;val localvalues localtypesitLjava/util/Iterator;column typeObjecte1inProgressSubMessageMapinProgressSubMessageListMapjsonsubsubMessageImplmsgselement5Ljava/util/Map;hLjava/util/Iterator;>;RLjava/util/Map$Entry;NLjava/util/Map;`Ljava/util/Map;>; SourceFileReplicationJSON.javaBootstrapMethods "java/lang/invoke/LambdaMetafactory  metafactory(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;'dg InnerClasses%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandlesLookupDecoderEncoderEntry!  7 Y ()  /*&  !"#%'( ] +*,)-/-  23 45 6  47 8"#%'9 ] +*,:-/1  => 45 6  47 ?@ ;*A5DEFG ?C ܸH N RNUYW:*X\b f-*im fsNvY*xSY*{SY*SY*S----*i:]Y\NY-OP#O%N9:;#<1=8?C@JAPBQCDEFGJKOPQHDEFGG:1Q 9En"nUI#[#T I%  D*ĹʰVDE +,"#% +*M,Mѻ]Y*,,[\] ^_*23 H +<"#% :+*ܰe=>   +,W-Y,-Y:j 6 t{Sw`./22|l("\ uxr; t>ɧCBh ~ hpBbTF+]W+W+!W+$&W)+)+W+$&W+.0W+]W]+]W!3Y578::+W]+]W!3Y>78::+W+@:*DFJ:LWH+PVWW2+]_W+]W`-b0ij kmop-r[thuiwvxwz{}~  !$8BCLZbex{f efghihjkFG h8 lhLmnZ Hn.%z]  ! o 2e++p*YMB 6 s{Sw`./22|l("\ uxr;t> ,ҧ,,h,{,),,z,Tm, _`, JS,%F,@9, ,+r+wz+~++++r+  +r+JNY:-:Ps:wzW)rW+3Y57+r:+rb3Y>7+r:+rb]Y+rİ:+rb+r*b 3>?' .3;CKS[`x}  "13?APRWcReihe}lncA"A6 c&x]  IV]s]JD&]s]JDs ]s]JD ]s]QQK kl M*,*W,*W,*WN*:]:-W,-W*:,2NY*x *{ -,>,=D`gqz    HEFGfDEn`gh.0-5I-J$I-.   N*-W+:+:a::!]:$]: ( W *--!]W:+/ +0:*3W+/L+/:-:!]*5W+0+0:c::!]W*D:  :  :  59W z9AM[fz !#$%& %)*=+E,W-c.{/.*4fFG<f=9R>AJefM>gh[0ih ?f@>=T@>ELAnc. { D 64B9RC@D=T@Ec.F ---]---"---) ------= ---JD --- --- 78 VM,ĶW,GW,IMWN,-W,*NP--R,@C. 79:;*<1=:>@?D@PATC4VVFGOf1nDC- +1'S : +ܶT+ܶTrM+޶T+޶T~GB+T+TrWZI:+TJ:<Y::  s:rW ]:`:+d: +hT-: *jj,! j ptx|>HI4JVKbMgNpOPORSUXYZz 45fh4VLbnp0< g5/ #f 6*47p0<5S @]]BB% k-]JD k-]JD fg *T-LYMYN++::!]:*-:(T:7YN*:  r:  T: , W- Wf-:,:*3T-:: : :  :  !]:  *s:-.-:d: Y:   WlJdJ:Y::#s:-d:W Y:   `W 9  :  : ::,-:  [}#6_ `abc%d(e4f@gLhVi[k}lmpqrsdvwx}~ %,1:FQXawB f f==%4>@{OhLofVe  %ih jk 0=*}=?f==2=2== =  >  Oh %!f,XZnaQw  6B%40B*}22    aQF(--W --]-s#+-- , ---G---]s-!---]sJD---]sJD ---D ---D---  *I@Q XQ