71com/dexels/replication/factory/ReplicationFactoryjava/lang/Objectinstance5Lcom/dexels/replication/api/ReplicationMessageParser; noopCommitLjava/lang/Runnable;()VCode run()Ljava/lang/Runnable;  LineNumberTableLocalVariableTable   this3Lcom/dexels/replication/factory/ReplicationFactory;setReplicationMessageParser8(Lcom/dexels/replication/api/ReplicationMessageParser;)VRuntimeInvisibleAnnotations2Lorg/osgi/service/component/annotations/Reference;policy8Lorg/osgi/service/component/annotations/ReferencePolicy;DYNAMICunbindclearReplicationMessageParsertarget(name=universal) % & setInstancermp getInstance7()Lcom/dexels/replication/api/ReplicationMessageParser; + parser clearInstancecreateReplicationMessage-(Ljava/util/Optional;Ljava/util/Optional;Ljava/util/Optional;Ljava/lang/String;JLcom/dexels/replication/api/ReplicationMessage$Operation;Ljava/util/List;Ljava/util/Map;Ljava/util/Map;Ljava/util/Map;Ljava/util/Map;Ljava/util/Optional;Ljava/util/Optional;)Lcom/dexels/replication/api/ReplicationMessage; Signature(Ljava/util/Optional;Ljava/util/Optional;Ljava/util/Optional;Ljava/lang/String;JLcom/dexels/replication/api/ReplicationMessage$Operation;Ljava/util/List;Ljava/util/Map;Ljava/util/Map;Ljava/util/Map;Ljava/util/Map;>;Ljava/util/Optional;Ljava/util/Optional;)Lcom/dexels/replication/api/ReplicationMessage;3;com/dexels/replication/impl/ReplicationImmutableMessageImpl 25 6(Ljava/util/Optional;Ljava/util/Optional;Ljava/util/Optional;Ljava/lang/String;Lcom/dexels/replication/api/ReplicationMessage$Operation;JLjava/util/Map;Ljava/util/Map;Ljava/util/Map;Ljava/util/Map;Ljava/util/List;Ljava/util/Optional;Ljava/util/Optional;)VsourceLjava/util/Optional; partitionoffset transactionIdLjava/lang/String; timestampJ operation9Lcom/dexels/replication/api/ReplicationMessage$Operation; primaryKeysLjava/util/List;typesLjava/util/Map;values subMessageMapsubMessageListMap commitAction paramMessageLocalVariableTypeTable(Ljava/util/Optional;)Ljava/util/Optional;&Ljava/util/Optional;$Ljava/util/List;5Ljava/util/Map;5Ljava/util/Map;NLjava/util/Map;`Ljava/util/Map;>;*Ljava/util/Optional;ALjava/util/Optional;(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;(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; 2X Y(Ljava/util/Optional;Ljava/util/Optional;Ljava/util/Optional;Ljava/lang/String;Lcom/dexels/replication/api/ReplicationMessage$Operation;JLcom/dexels/immutable/api/ImmutableMessage;Ljava/util/List;Ljava/util/Optional;Ljava/util/Optional;)Vmessage+Lcom/dexels/immutable/api/ImmutableMessage;fromMapa(Ljava/lang/String;Ljava/util/Map;Ljava/util/Map;)Lcom/dexels/replication/api/ReplicationMessage;(Ljava/lang/String;Ljava/util/Map;Ljava/util/Map;)Lcom/dexels/replication/api/ReplicationMessage; `bajava/util/Collections cd emptyList()Ljava/util/List;fjava/lang/String hjijava/util/Arrays klasList%([Ljava/lang/Object;)Ljava/util/List; npojava/util/Optional qrempty()Ljava/util/Optional; tvujava/lang/System wxcurrentTimeMillis()J z|{7com/dexels/replication/api/ReplicationMessage$Operation }@NONE ` emptyMap()Ljava/util/Map; n of((Ljava/lang/Object;)Ljava/util/Optional;  ./keykeys StackMapTablejava/util/ListcreateO(Ljava/util/Map;Ljava/util/Map;)Lcom/dexels/replication/api/ReplicationMessage;(Ljava/util/Map;Ljava/util/Map;)Lcom/dexels/replication/api/ReplicationMessage;@(Ljava/util/Map;)Lcom/dexels/replication/api/ReplicationMessage;f(Ljava/util/Map;)Lcom/dexels/replication/api/ReplicationMessage; 2 (Ljava/util/Map;)VdataMap1()Lcom/dexels/replication/api/ReplicationMessage;joinReplicationMessage(Ljava/lang/String;Lcom/dexels/replication/api/ReplicationMessage;Lcom/dexels/replication/api/ReplicationMessage;)Lcom/dexels/replication/api/ReplicationMessage; 2 s(Lcom/dexels/replication/api/ReplicationMessage;Lcom/dexels/replication/api/ReplicationMessage;Ljava/lang/String;)Va/Lcom/dexels/replication/api/ReplicationMessage;bcreateErrorReplicationMessageF(Ljava/lang/Throwable;)Lcom/dexels/replication/api/ReplicationMessage; 2 (Ljava/lang/Throwable;)VtLjava/lang/Throwable;standardMessage\(Lcom/dexels/immutable/api/ImmutableMessage;)Lcom/dexels/replication/api/ReplicationMessage;msglambda$0 SourceFileReplicationFactory.java2Lorg/osgi/service/component/annotations/Component;namedexels.replication.factoryBootstrapMethods "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;    InnerClasses-com/dexels/replication/api/ReplicationMessage Operation%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandlesLookup!   )   /* e s!"s# =+$ '! =$  !' () $*$ & 3** () ,- =+* ,-, ./01 ,2Y*+,-     43 7898:8;<=>?@ABCDED FD GD H8 I8 Jf 7K9L:MANCOEP FQ GR HS IT .U0V 2Y*+,-  W8f 7898:8;<=>?@ABZ[H8 I8 J>7K9L:MANHS IT \]0^ <* _eY*SgNmmmsy-,+~~m <=*<<<ED<CD&BJ <EP<CO&N J 0 x(mmmsy_+*~~mA(ED(CDJ(EP(CO 0 E 2Y*F  DJ  P q L,mmmsy_~~~~mJ  I 2Y+,*N  <    3 2Y*R   L "2Ymmmy*_mmWV "[  ! s z@