7pAcom/dexels/replication/impl/json/JSONReplicationMessageParserImpljava/lang/Object3com/dexels/replication/api/ReplicationMessageParserloggerLorg/slf4j/Logger;includeNullValuesZ ConstantValue()VCode org/slf4j/LoggerFactory  getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;  LineNumberTableLocalVariableTable    thisCLcom/dexels/replication/impl/json/JSONReplicationMessageParserImpl; parseJsonu(Ljava/util/Optional;Lcom/fasterxml/jackson/databind/node/ObjectNode;)Lcom/dexels/replication/api/ReplicationMessage; Signature(Ljava/util/Optional;Lcom/fasterxml/jackson/databind/node/ObjectNode;)Lcom/dexels/replication/api/ReplicationMessage; &('0com/dexels/replication/impl/json/ReplicationJSON )" parseJSONsourceLjava/util/Optional;on0Lcom/fasterxml/jackson/databind/node/ObjectNode;LocalVariableTypeTable(Ljava/util/Optional; prettyPrint()Z 354-com/dexels/replication/api/ReplicationMessage 6  usePretty parseBytes3([B)Lcom/dexels/replication/api/ReplicationMessage; :<;java/util/Optional =>empty()Ljava/util/Optional; &@ AB objectMapper-Lcom/fasterxml/jackson/databind/ObjectMapper; &D EFparseReplicationMessaget([BLjava/util/Optional;Lcom/fasterxml/jackson/databind/ObjectMapper;)Lcom/dexels/replication/api/ReplicationMessage; HJI1com/dexels/replication/factory/ReplicationFactory KLcreateErrorReplicationMessageF(Ljava/lang/Throwable;)Lcom/dexels/replication/api/ReplicationMessage;N2com/fasterxml/jackson/core/JsonProcessingExceptionPjava/lang/Throwabledata[Be4Lcom/fasterxml/jackson/core/JsonProcessingException;Ljava/lang/Throwable; StackMapTableG(Ljava/util/Optional;[B)Lcom/dexels/replication/api/ReplicationMessage;[(Ljava/util/Optional;[B)Lcom/dexels/replication/api/ReplicationMessage; parseStreamF(Ljava/io/InputStream;)Lcom/dexels/replication/api/ReplicationMessage; \ Y]Z(Ljava/util/Optional;Ljava/io/InputStream;)Lcom/dexels/replication/api/ReplicationMessage;Ljava/io/InputStream;n(Ljava/util/Optional;Ljava/io/InputStream;)Lcom/dexels/replication/api/ReplicationMessage; acb+com/fasterxml/jackson/databind/ObjectMapper dereadTree@(Ljava/io/InputStream;)Lcom/fasterxml/jackson/databind/JsonNode;g.com/fasterxml/jackson/databind/node/ObjectNodeijava/io/IOExceptionnode)Lcom/fasterxml/jackson/databind/JsonNode;Ljava/io/IOException;parseMessageList((Ljava/util/Optional;[B)Ljava/util/List;m(Ljava/util/Optional;[B)Ljava/util/List; aq dr-([B)Lcom/fasterxml/jackson/databind/JsonNode; t uv parseJSONNodeO(Ljava/util/Optional;Lcom/fasterxml/jackson/databind/JsonNode;)Ljava/util/List;xjava/util/LinkedList w {}|java/util/List ~add(Ljava/lang/Object;)Z java/util/Collections unmodifiableList"(Ljava/util/List;)Ljava/util/List;resultLjava/util/List;ALjava/util/List;(Ljava/util/Optional;Lcom/fasterxml/jackson/databind/JsonNode;)Ljava/util/List;-com/fasterxml/jackson/databind/node/ArrayNodeFNode is not an array, so can't parse to list, will create list of one! org/slf4j/Logger warn(Ljava/lang/String;)V iterator()Ljava/util/Iterator; java/util/Iterator next()Ljava/lang/Object;'com/fasterxml/jackson/databind/JsonNode 1hasNextsingle/Lcom/dexels/replication/api/ReplicationMessage;elements/Lcom/fasterxml/jackson/databind/node/ArrayNode;jsonNodeserializeMessageList(Ljava/util/List;)[BE(Ljava/util/List;)[B a createArrayNode1()Lcom/fasterxml/jackson/databind/node/ArrayNode; { stream()Ljava/util/stream/Stream; applyb(Lcom/dexels/replication/impl/json/JSONReplicationMessageParserImpl;)Ljava/util/function/Function; java/util/stream/Stream map8(Ljava/util/function/Function;)Ljava/util/stream/Stream; acceptN(Lcom/fasterxml/jackson/databind/node/ArrayNode;)Ljava/util/function/Consumer; forEach (Ljava/util/function/Consumer;)V 3 1usePrettyPrint a writerWithDefaultPrettyPrinter/()Lcom/fasterxml/jackson/databind/ObjectWriter; a writer +com/fasterxml/jackson/databind/ObjectWriter writeValueAsBytes(Ljava/lang/Object;)[BError: error*(Ljava/lang/String;Ljava/lang/Throwable;)Vlistw-Lcom/fasterxml/jackson/databind/ObjectWriter; serialize3(Lcom/dexels/replication/api/ReplicationMessage;)[B & jsonSerializer4(Lcom/dexels/replication/api/ReplicationMessage;Z)[BmsgdescribeC(Lcom/dexels/replication/api/ReplicationMessage;)Ljava/lang/String; &  jsonDescriberx(Lcom/dexels/replication/api/ReplicationMessage;Lcom/dexels/replication/api/ReplicationMessageParser;)Ljava/lang/String;;(Ljava/util/Optional;Ljava/io/InputStream;)Ljava/util/List;(Ljava/util/Optional;Ljava/io/InputStream;)Ljava/util/List;([B)Ljava/util/List;E([B)Ljava/util/List;  mnZ(Lcom/dexels/pubsub/rx2/api/PubSubMessage;)Lcom/dexels/replication/api/ReplicationMessage; 'com/dexels/pubsub/rx2/api/PubSubMessage value()[B  78 H =1()Lcom/dexels/replication/api/ReplicationMessage; 7com/dexels/replication/api/ReplicationMessage$Operation DELETE9Lcom/dexels/replication/api/ReplicationMessage$Operation; 3  withOperationj(Lcom/dexels/replication/api/ReplicationMessage$Operation;)Lcom/dexels/replication/api/ReplicationMessage;   > partition 3    withPartitionE(Ljava/util/Optional;)Lcom/dexels/replication/api/ReplicationMessage;  >offset 3   withOffset  >topic 3   withSource_kafkapartition java/lang/Integer  !valueOf(I)Ljava/lang/Integer; :# $%orElse&(Ljava/lang/Object;)Ljava/lang/Object;'integer 3) *+withg(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/String;)Lcom/dexels/replication/api/ReplicationMessage;- _kafkaoffset 132java/lang/Long  4(J)Ljava/lang/Long;6long8 _kafkakey : ;<key()Ljava/lang/String;>string@ _kafkatopic)Lcom/dexels/pubsub/rx2/api/PubSubMessage;lambda$0a(Lcom/dexels/replication/api/ReplicationMessage;)Lcom/fasterxml/jackson/databind/node/ObjectNode; &E FGtoJSONb(Lcom/dexels/replication/api/ReplicationMessage;Z)Lcom/fasterxml/jackson/databind/node/ObjectNode;lambda$1b(Lcom/fasterxml/jackson/databind/node/ArrayNode;Lcom/fasterxml/jackson/databind/node/ObjectNode;)V K ~LZ(Lcom/fasterxml/jackson/databind/JsonNode;)Lcom/fasterxml/jackson/databind/node/ArrayNode; SourceFile%JSONReplicationMessageParserImpl.javaRuntimeInvisibleAnnotations2Lorg/osgi/service/component/annotations/Component;namedexels.replication.parser.jsonproperty name=jsonBootstrapMethods WYX"java/lang/invoke/LambdaMetafactory Z[ 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;V% _ BC^C(Ljava/lang/Object;)Vb e HId3(Lcom/fasterxml/jackson/databind/node/ObjectNode;)Vg InnerClasses Operationl%java/lang/invoke/MethodHandles$Lookupnjava/lang/invoke/MethodHandlesLookup!    ) < **    !"#$V+,%#  *+,-. */01.2'  78++9?CM,GM,GMO+,/0123* QRSTSUV JMEO7W#X,,+?CN-GN-GMO:;>?@AB4 *+QRSTSU. */V HMEOYZ= *9+[I  Q^Y]#_!?,`N+-f%:G:GMhPQRSTU>! !*+!Q^ jkSTSl. !*/V QMGhmn#o!G?,pN*+-sNwYy:-GzWNwYy:-GzWM+O* [\]^_%`+a,b5cAdRG G*+GQRjkST,SU5. G*/5V OM[Ouv#ctwYyN,),f:+%:-zW-,::#:f:-+%zW-6 ijklm'n0o5q;rQsXterov\ t t*+tjkl,-';9QkX ,-.t*/lV#5{:{#M?M+*,ř ?ȧ ?N-,ϰN-#>?M}~#9?@K4M MQF9@ ST. MQV2EFM:+ :+* m#!G?,`N*+-sNwYy:-GzWNwYy:-GzWM+O* %+,5ARG G*+GQ^jkST,SU5. G*/5V OM[Om#= *9+  QR7+*++ +++"&(,+.0"5(7+9=(?+"=(& !,7BZt QAVJ3BC:+D~  HI0*+J~ S-MNOPQsRS[sTU\]`a\cfhi3j@kmo