3 &J KL MN OP QRS T U VWX YZ[ J\ ] ^_ `a b ^c de df g Yh i j kl mno Op qr qs tuv wxyzlogLorg/apache/log4j/Logger;taskRepository:Lorg/dataone/cn/data/repository/ReplicationTaskRepository;replicationManager7Lorg/dataone/service/cn/replication/ReplicationManager; PAGE_SIZEI()VCodeLineNumberTableLocalVariableTablethis=Lorg/dataone/service/cn/replication/ReplicationTaskProcessor;runtask0Lorg/dataone/cn/data/repository/ReplicationTask;nowJpage*Lorg/springframework/data/domain/Pageable;taskListLjava/util/List;LocalVariableTypeTableBLjava/util/List; StackMapTableo{|} SourceFileReplicationTaskProcessor.java 01~  ()%Replication task processor executing.  +org/springframework/data/domain/PageRequest ./ 0 *+.org/dataone/cn/data/repository/ReplicationTaskNEW java/lang/StringBuilder"Replication task processor found: |  tasks to process. } 1 ,-   ;org/dataone/service/cn/replication/ReplicationTaskProcessor   %dataone.cn.replication.task.page.size java/lang/Objectjava/lang/Runnable(org/springframework/data/domain/Pageablejava/util/Listjava/util/Iterator)org/dataone/cn/ComponentActivationUtilityreplicationIsActive()Zorg/apache/log4j/Loggerdebug(Ljava/lang/Object;)Vjava/lang/SystemcurrentTimeMillis()J(II)V8org/dataone/cn/data/repository/ReplicationTaskRepository;findByStatusAndNextExecutionLessThanOrderByNextExecutionAscO(Ljava/lang/String;JLorg/springframework/data/domain/Pageable;)Ljava/util/List;append-(Ljava/lang/String;)Ljava/lang/StringBuilder;size()I(I)Ljava/lang/StringBuilder;toString()Ljava/lang/String;iterator()Ljava/util/Iterator;hasNextnext()Ljava/lang/Object; markInProcesssave&(Ljava/lang/Object;)Ljava/lang/Object;getPid)org/dataone/client/v1/types/D1TypeBuilderbuildIdentifier=(Ljava/lang/String;)Lorg/dataone/service/types/v1/Identifier;5org/dataone/service/cn/replication/ReplicationManagercreateAndQueueTasks,(Lorg/dataone/service/types/v1/Identifier;)I getLogger,(Ljava/lang/Class;)Lorg/apache/log4j/Logger;5org/dataone/service/cn/replication/ReplicationFactorygetReplicationTaskRepository<()Lorg/dataone/cn/data/repository/ReplicationTaskRepository;getReplicationManager9()Lorg/dataone/service/cn/replication/ReplicationManager;"org/dataone/configuration/SettingsgetConfiguration2()Lorg/apache/commons/configuration/Configuration;.org/apache/commons/configuration/ConfigurationgetInt(Ljava/lang/String;I)I!&' () *+ ,-./012/*34 56712P@Y N  - :Y:1 : WW˱3:"#$%&%',)P*o+t,-./144o89:;s<=,e>?56@ ,e>AB YCDEF7CG12I% ! "#$ȹ%3HI