public class org.apache.sling.event.impl.jobs.JobManagerImpl extends java.lang.Object implements org.apache.sling.event.jobs.JobManager, org.osgi.service.event.EventHandler, java.lang.Runnable { private final org.slf4j.Logger logger; private org.osgi.service.event.EventAdmin eventAdmin; private org.apache.sling.commons.scheduler.Scheduler scheduler; private org.apache.sling.event.impl.jobs.JobConsumerManager jobConsumerManager; private org.apache.sling.event.jobs.jmx.QueuesMBean queuesMBean; private org.apache.sling.commons.threads.ThreadPoolManager threadPoolManager; private org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration; private org.apache.sling.event.impl.jobs.stats.StatisticsManager statisticsManager; private org.apache.sling.event.impl.jobs.queues.QueueManager qManager; private volatile org.apache.sling.event.impl.jobs.tasks.CleanUpTask maintenanceTask; private org.apache.sling.event.impl.jobs.scheduling.JobSchedulerImpl jobScheduler; private volatile org.osgi.framework.ServiceRegistration changeListenerReg; public void () { java.lang.Class v; org.slf4j.Logger v; org.apache.sling.event.impl.jobs.JobManagerImpl v; v := @this: org.apache.sling.event.impl.jobs.JobManagerImpl; specialinvoke v.()>(); v = virtualinvoke v.(); v = staticinvoke (v); v. = v; return; } protected void activate(org.osgi.framework.BundleContext, java.util.Map) throws org.apache.sling.api.resource.LoginException { java.lang.String[] v; org.apache.sling.event.impl.jobs.tasks.CleanUpTask v; org.apache.sling.commons.scheduler.Scheduler v; java.util.Map v; java.lang.String v, v, v, v, v; java.util.Hashtable v; org.osgi.framework.ServiceRegistration v; org.slf4j.Logger v; org.apache.sling.api.resource.observation.ResourceChange$ChangeType v, v, v; org.apache.sling.event.impl.jobs.scheduling.JobSchedulerImpl v, v, v; org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v, v, v; org.osgi.framework.BundleContext v; org.apache.sling.event.impl.jobs.JobManagerImpl v; v := @this: org.apache.sling.event.impl.jobs.JobManagerImpl; v := @parameter: org.osgi.framework.BundleContext; v := @parameter: java.util.Map; v = new org.apache.sling.event.impl.jobs.scheduling.JobSchedulerImpl; v = v.; v = v.; specialinvoke v.(org.apache.sling.event.impl.jobs.config.JobManagerConfiguration,org.apache.sling.commons.scheduler.Scheduler,org.apache.sling.event.impl.jobs.JobManagerImpl)>(v, v, v); v. = v; v = new org.apache.sling.event.impl.jobs.tasks.CleanUpTask; v = v.; v = v.; specialinvoke v.(org.apache.sling.event.impl.jobs.config.JobManagerConfiguration,org.apache.sling.event.impl.jobs.scheduling.JobSchedulerImpl)>(v, v); v. = v; v = new java.util.Hashtable; specialinvoke v.()>(); v = v.; v = virtualinvoke v.(0); virtualinvoke v.("resource.paths", v); v = newarray (java.lang.String)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v = ; v = virtualinvoke v.(); v[1] = v; v = ; v = virtualinvoke v.(); v[2] = v; virtualinvoke v.("resource.change.types", v); virtualinvoke v.("service.vendor", "The Apache Software Foundation"); virtualinvoke v.("service.description", "Resource change listener for scheduled jobs"); v = v.; v = interfaceinvoke v.(class "Lorg/apache/sling/api/resource/observation/ResourceChangeListener;", v, v); v. = v; v = v.; v = ; interfaceinvoke v.("Apache Sling Job Manager started on instance {}", v); return; } protected void deactivate() { org.slf4j.Logger v, v; org.apache.sling.event.impl.jobs.scheduling.JobSchedulerImpl v; org.apache.sling.event.impl.jobs.JobManagerImpl v; java.lang.String v, v; org.osgi.framework.ServiceRegistration v, v; v := @this: org.apache.sling.event.impl.jobs.JobManagerImpl; v = v.; v = ; interfaceinvoke v.("Apache Sling Job Manager stopping on instance {}", v); v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); v. = null; label: v = v.; virtualinvoke v.(); v. = null; v = v.; v = ; interfaceinvoke v.("Apache Sling Job Manager stopped on instance {}", v); return; } public void run() { org.apache.sling.event.impl.jobs.tasks.CleanUpTask v; org.apache.sling.event.impl.jobs.JobManagerImpl v; v := @this: org.apache.sling.event.impl.jobs.JobManagerImpl; v = v.; if v == null goto label; virtualinvoke v.(); label: return; } public void handleEvent(org.osgi.service.event.Event) { org.apache.sling.event.impl.jobs.scheduling.JobSchedulerImpl v; org.osgi.service.event.Event v; org.apache.sling.event.impl.jobs.JobManagerImpl v; v := @this: org.apache.sling.event.impl.jobs.JobManagerImpl; v := @parameter: org.osgi.service.event.Event; v = v.; virtualinvoke v.(v); return; } public synchronized org.apache.sling.event.jobs.Statistics getStatistics() { org.apache.sling.event.jobs.Statistics v; org.apache.sling.event.impl.jobs.stats.StatisticsManager v; org.apache.sling.event.impl.jobs.JobManagerImpl v; v := @this: org.apache.sling.event.impl.jobs.JobManagerImpl; v = v.; v = virtualinvoke v.(); return v; } public java.lang.Iterable getTopicStatistics() { org.apache.sling.event.impl.jobs.stats.StatisticsManager v; org.apache.sling.event.impl.jobs.JobManagerImpl v; java.util.Collection v; java.util.Map v; v := @this: org.apache.sling.event.impl.jobs.JobManagerImpl; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); return v; } public org.apache.sling.event.jobs.Queue getQueue(java.lang.String) { org.apache.sling.event.impl.jobs.JobManagerImpl v; java.lang.String v, v; org.apache.sling.event.jobs.Queue v; org.apache.sling.event.impl.jobs.queues.QueueManager v; v := @this: org.apache.sling.event.impl.jobs.JobManagerImpl; v := @parameter: java.lang.String; v = v.; v = staticinvoke (v); v = virtualinvoke v.(v); return v; } public java.lang.Iterable getQueues() { java.lang.Iterable v; org.apache.sling.event.impl.jobs.JobManagerImpl v; org.apache.sling.event.impl.jobs.queues.QueueManager v; v := @this: org.apache.sling.event.impl.jobs.JobManagerImpl; v = v.; v = virtualinvoke v.(); return v; } private boolean internalRemoveJobById(java.lang.String, boolean) { org.apache.sling.api.resource.ResourceResolver v; boolean v, v, v, v, v; org.apache.sling.event.impl.jobs.JobManagerImpl v; org.apache.sling.event.jobs.Job v, v; org.osgi.service.event.EventAdmin v; java.lang.Throwable v, v; java.util.Calendar v; java.lang.String v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v, v, v, v, v; org.apache.sling.event.jobs.Job$JobState v; org.apache.sling.event.impl.jobs.JobHandler v; org.apache.sling.api.resource.Resource v; org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v, v, v, v, v; v := @this: org.apache.sling.event.impl.jobs.JobManagerImpl; v := @parameter: java.lang.String; v := @parameter: boolean; v = v.; interfaceinvoke v.("Trying to remove job {}", v); v = 1; v = virtualinvoke v.(v); if v == null goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = staticinvoke (v); interfaceinvoke v.("Found removal job: {}", v); label: v = v.; v = virtualinvoke v.(v); if v == null goto label; v = v; label: if v != 0 goto label; v = virtualinvoke v.(); if v == null goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = staticinvoke (v); interfaceinvoke v.("Unable to remove job - job is started: {}", v); label: v = 0; goto label; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = v.; v = virtualinvoke v.(); label: v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; interfaceinvoke v.(v); interfaceinvoke v.(); v = v.; interfaceinvoke v.("Removed job with id: {}", v); goto label; label: v = v.; interfaceinvoke v.("Unable to remove job with id - resource already removed: {}", v); label: v = v.; staticinvoke (v, "org/apache/sling/event/notification/job/REMOVED", v, null); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Unable to remove job at \u0001"); interfaceinvoke v.(v, v); v = 0; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; interfaceinvoke v.(); throw v; label: v = new org.apache.sling.event.impl.jobs.JobHandler; v = v.; specialinvoke v.(org.apache.sling.event.impl.jobs.JobImpl,org.apache.sling.event.jobs.consumer.JobExecutor,org.apache.sling.event.impl.jobs.config.JobManagerConfiguration)>(v, null, v); v = ; virtualinvoke v.(v, 1, null); label: v = v.; v = virtualinvoke v.(); interfaceinvoke v.("REMOVE OK : {}", v); goto label; label: v = v.; interfaceinvoke v.("Job for removal does not exist (anymore): {}", v); label: return v; catch org.apache.sling.api.resource.PersistenceException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public org.apache.sling.event.jobs.Job addJob(java.lang.String, java.util.Map) { org.apache.sling.event.impl.jobs.JobManagerImpl v; java.util.Map v; org.apache.sling.event.jobs.Job v; java.lang.String v; v := @this: org.apache.sling.event.impl.jobs.JobManagerImpl; v := @parameter: java.lang.String; v := @parameter: java.util.Map; v = virtualinvoke v.(v, v, null); return v; } public org.apache.sling.event.jobs.Job getJobById(java.lang.String) { java.lang.Throwable v, v; org.apache.sling.api.resource.ResourceResolver v; java.lang.String v, v, v, v, v, v, v, v; boolean v, v, v, v; org.slf4j.Logger v, v, v, v, v, v, v, v; java.util.Iterator v; org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v, v, v; org.apache.sling.event.impl.jobs.JobManagerImpl v; java.lang.Object v; java.lang.StringBuilder v; org.apache.sling.event.impl.jobs.JobImpl v; v := @this: org.apache.sling.event.impl.jobs.JobManagerImpl; v := @parameter: java.lang.String; v = v.; interfaceinvoke v.("Getting job by id: {}", v); v = v.; v = virtualinvoke v.(); v = new java.lang.StringBuilder; specialinvoke v.(int)>(64); label: virtualinvoke v.("/jcr:root"); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.("/element(*,"); virtualinvoke v.("slingevent:Job"); virtualinvoke v.(")[@"); virtualinvoke v.("slingevent:eventId"); virtualinvoke v.(" = \'"); virtualinvoke v.(v); virtualinvoke v.("\']"); v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); interfaceinvoke v.("Exceuting query: {}", v); label: v = virtualinvoke v.(); v = interfaceinvoke v.(v, "xpath"); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = v.; v = staticinvoke (v, v); if v == null goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = staticinvoke (v); interfaceinvoke v.("Found job with id {} = {}", v, v); label: interfaceinvoke v.(); return v; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Query syntax wrong \u0001"); interfaceinvoke v.(v, v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; interfaceinvoke v.(); throw v; label: v = v.; interfaceinvoke v.("Job not found with id: {}", v); return null; catch org.apache.sling.api.resource.QuerySyntaxException from label to label with label; catch org.apache.sling.api.resource.QuerySyntaxException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public org.apache.sling.event.jobs.Job getJob(java.lang.String, java.util.Map) { java.util.Iterator v; java.util.Map[] v, v; java.util.Collection v; org.apache.sling.event.impl.jobs.JobManagerImpl v; org.apache.sling.event.jobs.JobManager$QueryType v, v; java.util.Map v; java.lang.Object v; java.lang.String v; boolean v; v := @this: org.apache.sling.event.impl.jobs.JobManagerImpl; v := @parameter: java.lang.String; v := @parameter: java.util.Map; if v != null goto label; v = ; v = (java.util.Map[]) null; v = virtualinvoke v.(v, v, 1L, v); goto label; label: v = ; v = newarray (java.util.Map)[1]; v[0] = v; v = virtualinvoke v.(v, v, 1L, v); label: v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); return v; label: return null; } public boolean removeJobById(java.lang.String) { java.lang.String v; org.apache.sling.event.impl.jobs.JobManagerImpl v; boolean v; v := @this: org.apache.sling.event.impl.jobs.JobManagerImpl; v := @parameter: java.lang.String; v = specialinvoke v.(v, 1); return v; } public transient java.util.Collection findJobs(org.apache.sling.event.jobs.JobManager$QueryType, java.lang.String, long, java.util.Map[]) { byte v, v; java.util.Map v; java.util.Set v; org.apache.sling.event.impl.jobs.JobManagerImpl$Operation v; org.apache.sling.event.impl.jobs.JobManagerImpl v; java.lang.StringBuilder v; java.lang.Throwable v, v; long v, v; java.util.ArrayList v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.Map[] v; org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v, v, v; org.apache.sling.event.impl.jobs.JobImpl v; org.apache.sling.api.resource.ResourceResolver v; int[] v; boolean v, v, v, v, v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v; org.slf4j.Logger v, v; java.util.Iterator v, v; org.apache.sling.event.jobs.JobManager$QueryType v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Object v, v, v, v; v := @this: org.apache.sling.event.impl.jobs.JobManagerImpl; v := @parameter: org.apache.sling.event.jobs.JobManager$QueryType; v := @parameter: java.lang.String; v := @parameter: long; v := @parameter: java.util.Map[]; v = ; if v == v goto label; v = ; if v == v goto label; v = ; if v == v goto label; v = ; if v == v goto label; v = ; if v == v goto label; v = ; if v == v goto label; v = ; if v != v goto label; label: v = 1; goto label; label: v = 0; label: v = v; v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; v = virtualinvoke v.(); v = new java.lang.StringBuilder; specialinvoke v.(int)>(64); label: virtualinvoke v.("/jcr:root"); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.("/element(*,"); virtualinvoke v.("slingevent:Job"); virtualinvoke v.(")[@"); v = staticinvoke ("event.job.topic"); virtualinvoke v.(v); if v == null goto label; virtualinvoke v.(" = \'"); virtualinvoke v.(v); virtualinvoke v.("\'"); label: if v == 0 goto label; virtualinvoke v.(" and @"); v = staticinvoke ("slingevent:finishedState"); virtualinvoke v.(v); v = ; if v == v goto label; v = ; if v == v goto label; v = ; if v == v goto label; v = ; if v == v goto label; v = ; if v != v goto label; label: virtualinvoke v.(" = \'"); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.("\'"); goto label; label: v = ; if v != v goto label; virtualinvoke v.(" and (@"); v = staticinvoke ("slingevent:finishedState"); virtualinvoke v.(v); virtualinvoke v.(" = \'"); v = ; v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.("\' or @"); v = staticinvoke ("slingevent:finishedState"); virtualinvoke v.(v); virtualinvoke v.(" = \'"); v = ; v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.("\' or @"); v = staticinvoke ("slingevent:finishedState"); virtualinvoke v.(v); virtualinvoke v.(" = \'"); v = ; v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.("\' or @"); v = staticinvoke ("slingevent:finishedState"); virtualinvoke v.(v); virtualinvoke v.(" = \'"); v = ; v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.("\')"); goto label; label: virtualinvoke v.(" and not(@"); v = staticinvoke ("slingevent:finishedState"); virtualinvoke v.(v); virtualinvoke v.(")"); v = ; if v != v goto label; virtualinvoke v.(" and @"); v = staticinvoke ("event.job.started.time"); virtualinvoke v.(v); goto label; label: v = ; if v != v goto label; virtualinvoke v.(" and not(@"); v = staticinvoke ("event.job.started.time"); virtualinvoke v.(v); virtualinvoke v.(")"); label: if v == null goto label; v = lengthof v; if v <= 0 goto label; v = 0; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = interfaceinvoke v.(); if v == 0 goto label; if v != 0 goto label; virtualinvoke v.(" and ("); goto label; label: virtualinvoke v.(" or "); label: virtualinvoke v.(40); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = 1; label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); if v <= 0 goto label; v = virtualinvoke v.(0); goto label; label: v = 0; label: if v != 61 goto label; v = virtualinvoke v.(1); v = ; goto label; label: if v != 60 goto label; v = virtualinvoke v.(); if v <= 1 goto label; v = virtualinvoke v.(1); goto label; label: v = 0; label: if v != 61 goto label; v = ; v = virtualinvoke v.(2); goto label; label: v = ; v = virtualinvoke v.(1); goto label; label: if v != 62 goto label; v = virtualinvoke v.(); if v <= 1 goto label; v = virtualinvoke v.(1); goto label; label: v = 0; label: if v != 61 goto label; v = ; v = virtualinvoke v.(2); goto label; label: v = ; v = virtualinvoke v.(1); goto label; label: v = v; v = ; label: if v == 0 goto label; v = 0; virtualinvoke v.(64); goto label; label: virtualinvoke v.(" and @"); label: virtualinvoke v.(v); virtualinvoke v.(32); v = ; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; case 5: goto label; default: goto label; }; label: virtualinvoke v.(61); goto label; label: virtualinvoke v.(60); goto label; label: virtualinvoke v.("<="); goto label; label: virtualinvoke v.(62); goto label; label: virtualinvoke v.(">="); label: virtualinvoke v.(" \'"); v = interfaceinvoke v.(); virtualinvoke v.(v); virtualinvoke v.("\'"); goto label; label: virtualinvoke v.(41); v = v + 1; label: v = v + 1; goto label; label: if v <= 0 goto label; virtualinvoke v.(41); label: virtualinvoke v.("] order by @"); if v == 0 goto label; virtualinvoke v.("slingevent:finishedDate"); virtualinvoke v.(" descending"); goto label; label: virtualinvoke v.("slingevent:created"); virtualinvoke v.(" ascending"); label: v = virtualinvoke v.(); v = interfaceinvoke v.(v, "xpath"); v = 0L; label: v = interfaceinvoke v.(); if v == 0 goto label; v = v cmp 1L; if v < 0 goto label; v = v cmp v; if v >= 0 goto label; label: v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = v.; v = staticinvoke (v, v); if v == null goto label; v = v + 1L; interfaceinvoke v.(v); goto label; label: interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Query syntax wrong \u0001"); interfaceinvoke v.(v, v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; interfaceinvoke v.(); throw v; label: return v; catch org.apache.sling.api.resource.QuerySyntaxException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private org.apache.sling.event.jobs.Job addJobInternal(java.lang.String, java.util.Map, java.util.List) { org.apache.sling.api.resource.ResourceResolver v; java.util.Map v; boolean v; java.util.List v; org.apache.sling.event.impl.jobs.JobManagerImpl v; java.lang.Throwable v, v; java.lang.Object[] v; org.apache.sling.event.impl.jobs.config.QueueConfigurationManager$QueueInfo v; org.apache.sling.event.impl.jobs.config.TopologyCapabilities v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v; org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v, v, v, v, v; org.apache.sling.event.impl.jobs.config.QueueConfigurationManager v; org.apache.sling.event.impl.jobs.JobImpl v; v := @this: org.apache.sling.event.impl.jobs.JobManagerImpl; v := @parameter: java.lang.String; v := @parameter: java.util.Map; v := @parameter: java.util.List; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); if v != null goto label; v = null; goto label; label: v = virtualinvoke v.(v, v, v); label: v. = v; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; if v == null goto label; v = v.; v = newarray (java.lang.Object)[3]; v = staticinvoke (v, v); v[0] = v; v = v.; v[1] = v; v = v.; v[2] = v; interfaceinvoke v.("Persisting job {} into queue {}, target={}", v); goto label; label: v = v.; v = staticinvoke (v, v); v = v.; interfaceinvoke v.("Persisting job {} into queue {}", v, v); label: v = v.; v = virtualinvoke v.(); label: v = specialinvoke v.(v, v, v, v); v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); interfaceinvoke v.("ASSIGN OK {} : {}", v, v); goto label; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.("UNASSIGN OK : {}", v); label: interfaceinvoke v.(); return v; label: v := @caughtexception; v = v.; v = staticinvoke (v, v); v = dynamicinvoke "makeConcatWithConstants" (v) ("Exception during persisting new job \'\u0001\'"); interfaceinvoke v.(v, v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; interfaceinvoke v.(); throw v; label: if v == null goto label; interfaceinvoke v.("Unable to persist new job."); label: return null; catch org.apache.sling.api.resource.PersistenceException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private org.apache.sling.event.impl.jobs.JobImpl writeJob(org.apache.sling.api.resource.ResourceResolver, java.lang.String, java.util.Map, org.apache.sling.event.impl.jobs.config.QueueConfigurationManager$QueueInfo) throws org.apache.sling.api.resource.PersistenceException { org.apache.sling.api.resource.ResourceResolver v; java.lang.Integer v, v; java.util.Map v; boolean v, v, v; org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration v, v; java.util.Set v; org.apache.sling.event.impl.jobs.JobManagerImpl v; java.util.HashMap v; java.util.Calendar v, v; org.apache.sling.event.impl.jobs.config.QueueConfigurationManager$QueueInfo v; int v; java.lang.String v, v, v, v, v, v, v, v, v; org.slf4j.Logger v, v; java.util.Iterator v; org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v, v; java.lang.Object v, v, v; org.apache.sling.event.impl.jobs.JobImpl v; v := @this: org.apache.sling.event.impl.jobs.JobManagerImpl; v := @parameter: org.apache.sling.api.resource.ResourceResolver; v := @parameter: java.lang.String; v := @parameter: java.util.Map; v := @parameter: org.apache.sling.event.impl.jobs.config.QueueConfigurationManager$QueueInfo; v = v.; v = virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(v, v, v, v); v = new java.util.HashMap; specialinvoke v.()>(); if v == null goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); if v != 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(v, v); goto label; label: interfaceinvoke v.("slingevent:eventId", v); interfaceinvoke v.("event.job.topic", v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.("event.job.queuename", v); v = staticinvoke (0); interfaceinvoke v.("event.job.retrycount", v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("event.job.retries", v); v = staticinvoke (); interfaceinvoke v.("slingevent:created", v); v = staticinvoke (); interfaceinvoke v.("event.job.queued.time", v); v = ; interfaceinvoke v.("slingevent:application", v); v = v.; if v == null goto label; v = v.; interfaceinvoke v.("event.job.application", v); goto label; label: interfaceinvoke v.("event.job.application"); label: interfaceinvoke v.("sling:resourceType", "slingevent:Job"); v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = staticinvoke (v, v); interfaceinvoke v.("Storing new job {} at {}", v, v); label: staticinvoke (v, v, v); interfaceinvoke v.("slingevent:path", v); v = new org.apache.sling.event.impl.jobs.JobImpl; specialinvoke v.(java.lang.String,java.lang.String,java.util.Map)>(v, v, v); return v; } public void stopJobById(java.lang.String) { java.lang.String v; org.apache.sling.event.impl.jobs.JobManagerImpl v; v := @this: org.apache.sling.event.impl.jobs.JobManagerImpl; v := @parameter: java.lang.String; specialinvoke v.(v, 1); return; } private void stopJobById(java.lang.String, boolean) { org.apache.sling.event.impl.jobs.config.QueueConfigurationManager$QueueInfo v; java.lang.String v, v, v, v; org.apache.sling.event.jobs.Queue v; boolean v, v, v; org.apache.sling.event.jobs.Job$JobState v; org.apache.sling.event.impl.jobs.JobHandler v; org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v, v, v; org.apache.sling.event.impl.jobs.config.QueueConfigurationManager v; org.apache.sling.event.impl.jobs.JobManagerImpl v; org.apache.sling.event.jobs.Job v; org.apache.sling.event.impl.jobs.queues.QueueManager v; v := @this: org.apache.sling.event.impl.jobs.JobManagerImpl; v := @parameter: java.lang.String; v := @parameter: boolean; v = virtualinvoke v.(v); if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.