76com/dexels/kafka/streams/xml/XmlMessageTransformerImpljava/lang/Object9com/dexels/replication/transformer/api/MessageTransformerparser5Lcom/dexels/replication/api/ReplicationMessageParser;counter(Ljava/util/concurrent/atomic/AtomicLong;subtransformersLjava/util/List; SignatureMLjava/util/List;subTransformerDescriptions$Ljava/util/List;logZ definition0Lcom/dexels/kafka/streams/xml/parser/XMLElement;loggerLorg/slf4j/Logger;()VCode 1com/dexels/replication/factory/ReplicationFactory  getInstance7()Lcom/dexels/replication/api/ReplicationMessageParser; !  #%$org/slf4j/LoggerFactory &' getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger; ) LineNumberTableLocalVariableTableT(Ljava/util/Map;Lcom/dexels/kafka/streams/xml/parser/XMLElement;Ljava/lang/String;)V(Ljava/util/Map;Lcom/dexels/kafka/streams/xml/parser/XMLElement;Ljava/lang/String;)V 0 ,2&java/util/concurrent/atomic/AtomicLong 10 5 7java/util/ArrayList 60 : <  > @true CED.com/dexels/kafka/streams/xml/parser/XMLElement FGgetStringAttribute&(Ljava/lang/String;)Ljava/lang/String; IKJjava/lang/String LMequals(Ljava/lang/Object;)Z O Qlogged message found SUTorg/slf4j/Logger VWinfo(Ljava/lang/String;)V CY Z[ getChildren()Ljava/util/Vector; ]_^java/util/Vector `aiterator()Ljava/util/Iterator; cedjava/util/Iterator fgnext()Ljava/lang/Object; Ci jaenumerateAttributeNamesljava/util/HashMap npo*com/dexels/kafka/streams/api/CoreOperators qr"transformerParametersFromTopicName#(Ljava/lang/String;)Ljava/util/Map; kt ,u(Ljava/util/Map;)V wyx java/util/Map z{put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; c} ~hasNext()Z C getName()Ljava/lang/String; I hashCode()IrenameSubMessageremoverename flattenToLastjoinTransformationflattenToFirstflattenToColumnrenameSubMessagesjava/lang/StringBuilderrename: ,W append-(Ljava/lang/Object;)Ljava/lang/StringBuilder; toString java/util/List Madd applyL(Ljava/util/Map;)Lcom/dexels/replication/transformer/api/MessageTransformer;renameSubMessage: renameSubMessages: flattenToFirst:  (Lcom/dexels/kafka/streams/xml/XmlMessageTransformerImpl;Ljava/util/Map;)Lcom/dexels/replication/transformer/api/MessageTransformer;flattenToColumn: remove: joinTransformation: java/util/Optional of((Ljava/lang/Object;)Ljava/util/Optional; -com/dexels/kafka/streams/base/StreamOperators transformersFromChildrenK(Ljava/util/Optional;Ljava/util/Map;Ljava/lang/String;)Ljava/util/Optional;  isPresent ggetsink. I  startsWith(Ljava/lang/String;)ZEMessagetransformer ignoring tag: {}, as it seems to be a sink setting S V'(Ljava/lang/String;Ljava/lang/Object;)Vcustom: -(Ljava/lang/String;)Ljava/lang/StringBuilder;- (Ljava/util/Map;Lcom/dexels/kafka/streams/xml/parser/XMLElement;Ljava/util/Map;)Lcom/dexels/replication/transformer/api/MessageTransformer;this8Lcom/dexels/kafka/streams/xml/XmlMessageTransformerImpl;transformerRegistryLjava/util/Map;xesourceTopicNameLjava/lang/String;partLjava/util/Iterator; attributesnameLjava/util/Optional;LocalVariableTypeTable^Ljava/util/Map;(Ljava/util/Iterator;5Ljava/util/Map;QLjava/util/Optional; StackMapTableo(Ljava/util/Map;Lcom/dexels/replication/api/ReplicationMessage;)Lcom/dexels/replication/api/ReplicationMessage;(Ljava/util/Map;Lcom/dexels/replication/api/ReplicationMessage;)Lcom/dexels/replication/api/ReplicationMessage; _ java/util/Collections emptyMap()Ljava/util/Map;     logMessagea(Lcom/dexels/replication/api/ReplicationMessage;Lcom/dexels/replication/api/ReplicationMessage;)Vparamsinput/Lcom/dexels/replication/api/ReplicationMessage;msgmessageTransformer;Lcom/dexels/replication/transformer/api/MessageTransformer;-com/dexels/replication/api/ReplicationMessage 1 incrementAndGet()J S  isInfoEnabledApplying transformation: {}->{}Transforming in: {}  !queueKey# BEFORE: {} % &' toFlatStringI(Lcom/dexels/replication/api/ReplicationMessageParser;)Ljava/lang/String;) AFTER: {}+DONE--------------: output descriptionlambda$0~(Ljava/util/Map;Ljava/util/Map;Lcom/dexels/replication/api/ReplicationMessage;)Lcom/dexels/replication/api/ReplicationMessage;1from w3 4&(Ljava/lang/Object;)Ljava/lang/Object;6to 8 9U(Ljava/lang/String;Ljava/lang/String;)Lcom/dexels/replication/api/ReplicationMessage;pmessagelambda$1 > ?@ subMessage((Ljava/lang/String;)Ljava/util/Optional;B)com/dexels/immutable/api/ImmutableMessage D EFwithoutSubMessageC(Ljava/lang/String;)Lcom/dexels/replication/api/ReplicationMessage; H IJwithSubMessagen(Ljava/lang/String;Lcom/dexels/immutable/api/ImmutableMessage;)Lcom/dexels/replication/api/ReplicationMessage;fieldsrc+Lcom/dexels/immutable/api/ImmutableMessage;ALjava/util/Optional;lambda$2 Q R@ subMessages T UFwithoutSubMessages W XYwithSubMessagesS(Ljava/lang/String;Ljava/util/List;)Lcom/dexels/replication/api/ReplicationMessage;SLjava/util/Optional;>;lambda$3 ] ^isEmpty ` abstream()Ljava/util/stream/Stream; dfejava/util/stream/Stream gh findFirst()Ljava/util/Optional;jFlattening to firstfirst transformedlambda$4o p%()Ljava/util/function/BinaryOperator; dr streduce9(Ljava/util/function/BinaryOperator;)Ljava/util/Optional; vxw-com/dexels/immutable/factory/ImmutableFactory yzempty-()Lcom/dexels/immutable/api/ImmutableMessage; | }4orElselastlambda$6property A  columnValue&(Ljava/lang/String;)Ljava/lang/Object; A G columnType  withg(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/String;)Lcom/dexels/replication/api/ReplicationMessage;mmsglambda$7  Fwithoutlambda$8(Ljava/util/Map;Lcom/dexels/kafka/streams/xml/parser/XMLElement;Ljava/util/Map;Ljava/util/Map;Lcom/dexels/replication/api/ReplicationMessage;)Lcom/dexels/replication/api/ReplicationMessage;java/lang/NullPointerExceptionNo message transformer found: *Exception in transforming! Transformer: {} S error9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)Vjava/lang/ThrowabletLjava/lang/Throwable;lambda$5(Lcom/dexels/immutable/api/ImmutableMessage;Lcom/dexels/immutable/api/ImmutableMessage;)Lcom/dexels/immutable/api/ImmutableMessage;ab SourceFileXmlMessageTransformerImpl.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;  ./  </  O/  [/  m/  /  /  {   InnerClasses%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandlesLookup!      3 "(* !+,- .< P*/*1Y34*6Y89*6Y8;*,=*?,ABHN*N (PR,X\:bC:h:kY-ms: bI:BvW|Y:?IJVK7>cspj}RQ~GHHHoHGHHwHHHd*;YW*9W*;YW*9W*;YW*9W_*;YW*9*W/*;YW*9W*;YW*9W*;YW*9W*;YW+-:  Ιs*9 W^Զ֙(?*;Y߷W*9+W| *1$%%*&9'@(J*b+i,v-y./-2\4w58:;HJKUWXkm4nE|H~ctw 1E*O+\ PPPPbijv *Pijv |JwCI wCIc"wCICccw]I .../...C;wCIc II,N*9:#b:+ +-N|*N *,--*0:AG+4II I  G   I ~wcwcwcwwcw 3*4X((*=*;:bIN(-|(,("+$((,$(*R*. ";GQbv+*  , ; -'0cM ./e,*02I*52I7*6+:;  : </I*02IN*52I:,-=:Κ,A:,-CG*< =>$?,@.B8C+>I:I;  <K.6$%18LMI:$%1N.II O/E*02IN*52I:,-P:Κ,,-SV*M NO$P,Q.S+4E:E;  8K*6$!1E:$!1Z.II[/e +02I:+52I:-P:Κ-\-_cA:-SG:*N(iR*-*6 Z[\&].^0`@aBc\doevfgi+R:; }Ko6&e1\/kMol :&e1Z0IIEA m/ s*02IN*52I:,-P:Κ,\,_nqu{A:,-SG*& p qr$s,t.v>w@ybz+>s:s;  fKX6$O1b~Ms:$O1Z.II /)g*02IN*52I:*2I:,-=:Κ,A:,-C*" )2:<F+Hg:g;  ZL6)>251F!Mg:251N<wwIII /n,,*2I*+:;  :Q Q*+2:YY+,:(+0:;*0;=N+*Q:Q; B= Q: 0J 6+*y+MM\