3 @{ |} ;~ ; ; ; {  ;      ; ;  $  ;     6 6  logLorg/apache/log4j/Logger;hzClient&Lcom/hazelcast/client/HazelcastClient;systemMetadataMapLjava/lang/String;systemMetadataLcom/hazelcast/core/IMap; SignatureqLcom/hazelcast/core/IMap;replicationTaskRepository:Lorg/dataone/cn/data/repository/ReplicationTaskRepository;()VCodeLineNumberTableLocalVariableTablethis=Lorg/dataone/service/cn/replication/ReplicationEventListener;init entryAdded"(Lcom/hazelcast/core/EntryEvent;)VeventLcom/hazelcast/core/EntryEvent;LocalVariableTypeTablewLcom/hazelcast/core/EntryEvent; StackMapTablez(Lcom/hazelcast/core/EntryEvent;)V entryUpdatedcreateReplicationTask,(Lorg/dataone/service/types/v1/Identifier;)V identifier)Lorg/dataone/service/types/v1/Identifier;existingTaskListLjava/util/List;BLjava/util/List;isAuthoritativeReplicaValid0(Lorg/dataone/service/types/v2/SystemMetadata;)ZsysMeta-Lorg/dataone/service/types/v2/SystemMetadata;status0Lorg/dataone/service/types/v1/ReplicationStatus;getAuthoritativeMNReplicaStatus_(Lorg/dataone/service/types/v2/SystemMetadata;)Lorg/dataone/service/types/v1/ReplicationStatus;replica&Lorg/dataone/service/types/v1/Replica;authNode,Lorg/dataone/service/types/v1/NodeReference; entryRemoved entryEvictedLjava/lang/Object;Lcom/hazelcast/core/EntryListener; SourceFileReplicationEventListener.java NO DE FG HI BCjava/lang/StringBuilderAdded a listener to the  map.   LM initialization @Received entry added event on the hzSystemMetadata map for pid:  'org/dataone/service/types/v1/Identifier +org/dataone/service/types/v2/SystemMetadata gh _`IAuthoritative replica is not valid, not queueing to replication for pid: BReceived entry updated event on the hzSystemMetadata map for pid: >Replication Event Listener received event with null identifier   .org/dataone/cn/data/repository/ReplicationTask N` 4Found more than one replication task object for pid:". Deleting and creating new task. mn l "authoritative MN is null for pid:   $org/dataone/service/types/v1/Replica  replica list is null for pid: ;org/dataone/service/cn/replication/ReplicationEventListener    dataone.hazelcast.systemMetadata   java/lang/Object com/hazelcast/core/EntryListenerjava/util/List*org/dataone/service/types/v1/NodeReferencejava/util/Iterator/org/dataone/cn/hazelcast/HazelcastClientFactorygetStorageClient(()Lcom/hazelcast/client/HazelcastClient;$com/hazelcast/client/HazelcastClientgetMap-(Ljava/lang/String;)Lcom/hazelcast/core/IMap;com/hazelcast/core/IMapaddEntryListener&(Lcom/hazelcast/core/EntryListener;Z)Vappend-(Ljava/lang/String;)Ljava/lang/StringBuilder;getName()Ljava/lang/String;toStringorg/apache/log4j/Loggerinfo(Ljava/lang/Object;)V5org/dataone/service/cn/replication/ReplicationFactorygetReplicationTaskRepository<()Lorg/dataone/cn/data/repository/ReplicationTaskRepository;getReplicationManager9()Lorg/dataone/service/cn/replication/ReplicationManager;)org/dataone/cn/ComponentActivationUtilityreplicationIsActive()Zcom/hazelcast/core/EntryEventgetKey()Ljava/lang/Object;getValueerror8org/dataone/cn/data/repository/ReplicationTaskRepository findByPid$(Ljava/lang/String;)Ljava/util/List;isEmptysave&(Ljava/lang/Object;)Ljava/lang/Object;size()Idelete(Ljava/lang/Iterable;)V.org/dataone/service/types/v1/ReplicationStatus COMPLETEDequals(Ljava/lang/Object;)ZgetAuthoritativeMemberNode.()Lorg/dataone/service/types/v1/NodeReference; getIdentifier+()Lorg/dataone/service/types/v1/Identifier;debuggetReplicaList()Ljava/util/List;iterator()Ljava/util/Iterator;hasNextnextgetReplicaMemberNodegetReplicationStatus2()Lorg/dataone/service/types/v1/ReplicationStatus; getLogger,(Ljava/lang/Class;)Lorg/apache/log4j/Logger;"org/dataone/configuration/SettingsgetConfiguration2()Lorg/apache/commons/configuration/Configuration;.org/apache/commons/configuration/Configuration getString&(Ljava/lang/String;)Ljava/lang/String;!;@A BCDEFGHIJKLM NOPV****** Y  *   *WQ"JL NP$QJRQTUUR VSTUOP7 Q [\R  STVWPgc Y  + *+*+% Y  + Q* ghi%h(k6lDnTocnfrRgSTgXYZ gX[\D!J]^WPgc Y  + *+*+% Y  + Q* }~%~(6DTcfRgSTgXYZ gX[\D!J]_`P#+ +  !*+"M,#*$Y+%&WJ,'@ Y ( + ) !*,**$Y+%&WQ> "+@JZhkuR STab"fcdZ "fce\  +fFghPg+*++M,,-Q R STij kl\mnP+.M,$ Y / +0 1+29+23N-4#-56:,78 9ڧ" Y : +0 1Q.  (*1O[agR*OopSTijqr\*st%uWPGQRSTXYZ X[J]vWPGQRSTXYZ X[J]wOP2;<=>?Q 6<Jxyz