Êþº¾7gEcom/dexels/replication/impl/json/JSONDumpReplicationMessageParserImpljava/lang/Object3com/dexels/replication/api/ReplicationMessageParserloggerLorg/slf4j/Logger;includeNullValuesZ ConstantValue()VCode org/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger; LineNumberTableLocalVariableTable thisGLcom/dexels/replication/impl/json/JSONDumpReplicationMessageParserImpl; 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 parseBytes3([B)Lcom/dexels/replication/api/ReplicationMessage; 576java/util/Optional89empty()Ljava/util/Optional; &;<=objectMapper-Lcom/fasterxml/jackson/databind/ObjectMapper; &?@AparseReplicationMessaget([BLjava/util/Optional;Lcom/fasterxml/jackson/databind/ObjectMapper;)Lcom/dexels/replication/api/ReplicationMessage; CED1com/dexels/replication/factory/ReplicationFactoryFGcreateErrorReplicationMessageF(Ljava/lang/Throwable;)Lcom/dexels/replication/api/ReplicationMessage;I2com/fasterxml/jackson/core/JsonProcessingExceptionKjava/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; WTXZ(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; \^]+com/fasterxml/jackson/databind/ObjectMapper_`readTree@(Ljava/io/InputStream;)Lcom/fasterxml/jackson/databind/JsonNode;b.com/fasterxml/jackson/databind/node/ObjectNodedjava/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; \l_m-([B)Lcom/fasterxml/jackson/databind/JsonNode; opq parseJSONNodeO(Ljava/util/Optional;Lcom/fasterxml/jackson/databind/JsonNode;)Ljava/util/List;sjava/util/LinkedList rvxwjava/util/Listyzadd(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/ArrayNodeˆFNode 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 \§¨©createArrayNode1()Lcom/fasterxml/jackson/databind/node/ArrayNode;v«¬stream()Ljava/util/stream/Stream;¯°±applyf(Lcom/dexels/replication/impl/json/JSONDumpReplicationMessageParserImpl;)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 \ÁÂÃwriter/()Lcom/fasterxml/jackson/databind/ObjectWriter; ÅÇÆ+com/fasterxml/jackson/databind/ObjectWriterÈÉwriteValueAsBytes(Ljava/lang/Object;)[BËError: ŠÍÎÏerror*(Ljava/lang/String;Ljava/lang/Throwable;)Vlistw-Lcom/fasterxml/jackson/databind/ObjectWriter; serialize3(Lcom/dexels/replication/api/ReplicationMessage;)[B &Ö×ØjsonSerializer5(Lcom/dexels/replication/api/ReplicationMessage;ZZ)[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; åhiZ(Lcom/dexels/pubsub/rx2/api/PubSubMessage;)Lcom/dexels/replication/api/ReplicationMessage;èêé'com/dexels/pubsub/rx2/api/PubSubMessageëìvalue()[B î23 Cð8ñ1()Lcom/dexels/replication/api/ReplicationMessage; óõô7com/dexels/replication/api/ReplicationMessage$Operationö÷DELETE9Lcom/dexels/replication/api/ReplicationMessage$Operation;ùûú-com/dexels/replication/api/ReplicationMessageüý withOperationj(Lcom/dexels/replication/api/ReplicationMessage$Operation;)Lcom/dexels/replication/api/ReplicationMessage;èÿ9 partitionù withPartitionE(Ljava/util/Optional;)Lcom/dexels/replication/api/ReplicationMessage;è9offsetù withOffsetè 9topicù withSource_kafkapartition java/lang/IntegervalueOf(I)Ljava/lang/Integer; 5orElse&(Ljava/lang/Object;)Ljava/lang/Object;integerù !"withg(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/String;)Lcom/dexels/replication/api/ReplicationMessage;$_kafkaoffsetÿÿÿÿÿÿÿÿ (*)java/lang/Long+(J)Ljava/lang/Long;-long/ _kafkakeyè123key()Ljava/lang/String;5string7_kafkatopic)Lcom/dexels/pubsub/rx2/api/PubSubMessage;lambda$0a(Lcom/dexels/replication/api/ReplicationMessage;)Lcom/fasterxml/jackson/databind/node/ObjectNode; &<=>toJSONb(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 …ByCZ(Lcom/fasterxml/jackson/databind/JsonNode;)Lcom/fasterxml/jackson/databind/node/ArrayNode; SourceFile)JSONDumpReplicationMessageParserImpl.javaRuntimeInvisibleAnnotations2Lorg/osgi/service/component/annotations/Component;name dexels.replication.parser.ndjsonpropertyname=ndjsonBootstrapMethods NPO"java/lang/invoke/LambdaMetafactoryQRmetafactoryÌ(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;M V9:U:(Ljava/lang/Object;)VY \?@[3(Lcom/fasterxml/jackson/databind/node/ObjectNode;)V^InnerClasses Operationc%java/lang/invoke/MethodHandles$Lookupejava/lang/invoke/MethodHandlesLookup! ) ¸³±< *·*µ± !"#$V+,¸%°, *+,-.*/01,¬0 23ž+Ç°+¸4²:¸>°M,¸B°M,¸B°HJ4589:;<* LMNONPQJHEJ2R#S¸,Ç°,+²:¸>°N-¸B°N-¸B°HJCDGHIJK4 *+LMNONP.*/QHHEJTU= *¸4+¶V°R LYTX#ZÃ!²:,¶[N+-Àa¸%°:¸B°:¸B°HcYZ[\]^>! !*+!LY efNONg.!*/Q QHGchi#j!G²:,¶kN*+-¶n°N»rY·t:-¸B¹uW¸{°N»rY·t:-¸B¹uW¸{°H+J* defgh%i+j,k5lAmRG G*+GLMefNO‚,NP5‚. G*/ƒ5ƒQ OH[Jpq#„ct»rY·tN,Á…š)²‡¹‰,Àa:+¸%:-¹uW-¸{°,À…:¶:§#¹“À™:Àa:-+¸%¹uW¹›šÿÙ-¸{°6 rstuv'w0x5z;{Q|X}e{o\ t t*+tefl‚,-'žŸ;9 ¡Q¢fX ,-.t*/lƒQ#ü5vÿ5™v…”£¤#¥Ý>²:¶¦M+¹ª*º®¹²,º¸¹¼²:¶ÀN-,¶Ä°N²Ê-¹Ì°#/0H†‡#‰*Š0‹1Œ<Ž4> >L‚7Ð¡*ÑÒ1 NO.>LƒQÿ0v…HÓÔ;+¸Õ°• ÙŸÚÛ:+*¸Ü°š ÙŸhà#á!G²:,¶[N*+-¶n°N»rY·t:-¸B¹uW¸{°N»rY·t:-¸B¹uW¸{°H+J* ¡¢£¤%¥+¦,§5¨A©RG G*+GLYefNO‚,NP5‚. G*/ƒ5ƒQ OH[Jhâ#ã= *¸4+¶ä°¯ LM2æü›+¹çÆ*+¹ç¶í§¸ï²ò¹ø+¹þ¹+¹¹+¹¹+¹þ¸¶¹#+¹%¸'¶,¹.+¹04¹6+¹¶4¹°& ´!µ,¶7·B¸Z¹tº…»š´› ›L8QJù9::+¸;°‡ ÙŸ ?@0*+¶A±‡N-DEFGHsIJ[sKLSTWXSZ]_`óùa@bdf