public class org.apache.sling.event.impl.jobs.config.JobManagerConfiguration extends java.lang.Object
{
private final org.slf4j.Logger logger;
private final org.slf4j.Logger auditLogger;
public static final java.lang.String DEFAULT_REPOSITORY_PATH;
public static final long DEFAULT_BACKGROUND_LOAD_DELAY;
public static final java.lang.String DEFAULT_SCHEDULED_JOBS_PATH;
public static final java.lang.String PROPERTY_REPOSITORY_PATH;
public static final java.lang.String PROPERTY_BACKGROUND_LOAD_DELAY;
public static final java.lang.String PROPERTY_SCHEDULED_JOBS_PATH;
private java.lang.String jobsBasePathWithSlash;
private java.lang.String assignedJobsPath;
private java.lang.String unassignedJobsPath;
private java.lang.String localJobsPath;
private java.lang.String localJobsPathWithSlash;
private java.lang.String previousVersionAnonPath;
private java.lang.String previousVersionIdentifiedPath;
private volatile long backgroundLoadDelay;
private volatile long startupDelay;
private volatile org.apache.sling.event.impl.discovery.InitDelayingTopologyEventListener startupDelayListener;
private volatile boolean disabledDistribution;
private java.lang.String storedCancelledJobsPath;
private java.lang.String storedSuccessfulJobsPath;
private java.lang.String scheduledJobsPath;
private java.lang.String scheduledJobsPathWithSlash;
private volatile int historyCleanUpRemovedJobs;
private final java.util.List listeners;
private org.apache.sling.event.impl.EnvironmentComponent environment;
private org.apache.sling.api.resource.ResourceResolverFactory resourceResolverFactory;
private org.apache.sling.event.impl.jobs.config.QueueConfigurationManager queueConfigManager;
private org.apache.sling.serviceusermapping.ServiceUserMapped serviceUserMapped;
private final java.util.concurrent.atomic.AtomicBoolean active;
private volatile org.apache.sling.event.impl.jobs.config.TopologyCapabilities topologyCapabilities;
private final java.util.concurrent.atomic.AtomicLong jobCounter;
private final java.util.Map retryList;
public void <init>()
{
java.util.concurrent.atomic.AtomicLong v;
org.slf4j.Logger v, v;
java.util.concurrent.atomic.AtomicBoolean v;
java.util.HashMap v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
java.util.ArrayList v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.String)>("org.apache.sling.event.impl.jobs");
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger logger> = v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.String)>("org.apache.sling.event.jobs.audit");
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger auditLogger> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.List listeners> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.concurrent.atomic.AtomicBoolean active> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.concurrent.atomic.AtomicLong jobCounter> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.Map retryList> = v;
return;
}
static org.apache.sling.event.impl.jobs.config.JobManagerConfiguration newForTest(org.apache.sling.api.resource.ResourceResolverFactory, org.apache.sling.event.impl.jobs.config.QueueConfigurationManager, java.util.Map, org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$Config)
{
org.apache.sling.api.resource.ResourceResolverFactory v;
java.util.Map v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$Config v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
org.apache.sling.event.impl.jobs.config.QueueConfigurationManager v;
v := @parameter: org.apache.sling.api.resource.ResourceResolverFactory;
v := @parameter: org.apache.sling.event.impl.jobs.config.QueueConfigurationManager;
v := @parameter: java.util.Map;
v := @parameter: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$Config;
v = new org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
specialinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: void <init>()>();
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.api.resource.ResourceResolverFactory resourceResolverFactory> = v;
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.event.impl.jobs.config.QueueConfigurationManager queueConfigManager> = v;
virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: void activate(java.util.Map,org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$Config)>(v, v);
return v;
}
protected void activate(java.util.Map, org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$Config)
{
org.apache.sling.api.resource.ResourceResolver v;
byte v;
java.lang.Long v, v, v, v;
java.util.Map v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$1 v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$Config v;
org.apache.sling.event.impl.discovery.InitDelayingTopologyEventListener v;
java.lang.Throwable v, v;
java.util.concurrent.atomic.AtomicBoolean v;
long v, v, v, v, v, v;
int 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, v, v, v, v, v;
org.slf4j.Logger v, v, v;
java.lang.RuntimeException v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
java.lang.Object v, v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v := @parameter: java.util.Map;
v := @parameter: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$Config;
virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: void update(java.util.Map,org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$Config)>(v, v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("repository.path");
v = staticinvoke <org.apache.sling.commons.osgi.PropertiesUtil: java.lang.String toString(java.lang.Object,java.lang.String)>(v, "/var/eventing/jobs");
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/");
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String jobsBasePathWithSlash> = v;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String jobsBasePathWithSlash>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001assigned");
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String assignedJobsPath> = v;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String jobsBasePathWithSlash>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001unassigned");
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String unassignedJobsPath> = v;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String assignedJobsPath>;
v = virtualinvoke v.<java.lang.String: java.lang.String concat(java.lang.String)>("/");
v = <org.apache.sling.event.impl.support.Environment: java.lang.String APPLICATION_ID>;
v = virtualinvoke v.<java.lang.String: java.lang.String concat(java.lang.String)>(v);
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String localJobsPath> = v;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String localJobsPath>;
v = virtualinvoke v.<java.lang.String: java.lang.String concat(java.lang.String)>("/");
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String localJobsPathWithSlash> = v;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String jobsBasePathWithSlash>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001anon");
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String previousVersionAnonPath> = v;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String jobsBasePathWithSlash>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001identified");
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String previousVersionIdentifiedPath> = v;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String jobsBasePathWithSlash>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001cancelled");
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String storedCancelledJobsPath> = v;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String jobsBasePathWithSlash>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001finished");
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String storedSuccessfulJobsPath> = v;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("job.scheduled.jobs.path");
v = staticinvoke <org.apache.sling.commons.osgi.PropertiesUtil: java.lang.String toString(java.lang.Object,java.lang.String)>(v, "/var/eventing/scheduled-jobs");
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String scheduledJobsPath> = v;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String scheduledJobsPath>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/");
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String scheduledJobsPathWithSlash> = v;
v = interfaceinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$Config: int cleanup_period()>();
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: int historyCleanUpRemovedJobs> = v;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.api.resource.ResourceResolver createResourceResolver()>();
label:
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String getLocalJobsPath()>();
staticinvoke <org.apache.sling.event.impl.support.ResourceHelper: void getOrCreateBasePath(org.apache.sling.api.resource.ResourceResolver,java.lang.String)>(v, v);
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String getUnassignedJobsPath()>();
staticinvoke <org.apache.sling.event.impl.support.ResourceHelper: void getOrCreateBasePath(org.apache.sling.api.resource.ResourceResolver,java.lang.String)>(v, v);
label:
interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: void close()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger logger>;
v = virtualinvoke v.<org.apache.sling.api.resource.PersistenceException: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Unable to create default paths: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>(v, v);
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v := @caughtexception;
interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: void close()>();
throw v;
label:
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.concurrent.atomic.AtomicBoolean active>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(1);
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: long startupDelay>;
v = v cmp 0L;
if v <= 0 goto label;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger logger>;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: long startupDelay>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = interfaceinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$Config: long startup_delay()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("activate: job manager will start in {} sec. ({})", v, v);
v = new org.apache.sling.event.impl.discovery.InitDelayingTopologyEventListener;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: long startupDelay>;
v = new org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$1;
specialinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$1: void <init>(org.apache.sling.event.impl.jobs.config.JobManagerConfiguration)>(v);
specialinvoke v.<org.apache.sling.event.impl.discovery.InitDelayingTopologyEventListener: void <init>(long,org.apache.sling.discovery.TopologyEventListener)>(v, v);
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.event.impl.discovery.InitDelayingTopologyEventListener startupDelayListener> = v;
goto label;
label:
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger logger>;
v = interfaceinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$Config: long startup_delay()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: long startupDelay>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("activate: job manager will start without delay. ({}:{})", v, v);
label:
return;
catch org.apache.sling.api.resource.PersistenceException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
protected void update(java.util.Map, org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$Config)
{
java.util.Map v;
java.lang.Object v;
long v, v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$Config v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
boolean v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v := @parameter: java.util.Map;
v := @parameter: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$Config;
v = interfaceinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$Config: boolean job_consumermanager_disableDistribution()>();
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: boolean disabledDistribution> = v;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("load.delay");
v = staticinvoke <org.apache.sling.commons.osgi.PropertiesUtil: long toLong(java.lang.Object,long)>(v, 10L);
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: long backgroundLoadDelay> = v;
v = interfaceinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$Config: long startup_delay()>();
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: long startupDelay> = v;
return;
}
protected void deactivate()
{
org.apache.sling.event.impl.discovery.InitDelayingTopologyEventListener v, v;
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.concurrent.atomic.AtomicBoolean active>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(0);
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.event.impl.discovery.InitDelayingTopologyEventListener startupDelayListener>;
if v == null goto label;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.event.impl.discovery.InitDelayingTopologyEventListener startupDelayListener>;
virtualinvoke v.<org.apache.sling.event.impl.discovery.InitDelayingTopologyEventListener: void dispose()>();
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.event.impl.discovery.InitDelayingTopologyEventListener startupDelayListener> = null;
label:
specialinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: void stopProcessing()>();
return;
}
public int getHistoryCleanUpRemovedJobs()
{
int v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: int historyCleanUpRemovedJobs>;
return v;
}
public boolean isActive()
{
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
boolean v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.concurrent.atomic.AtomicBoolean active>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
return v;
}
public org.apache.sling.api.resource.ResourceResolver createResourceResolver()
{
java.lang.Throwable v;
org.apache.sling.api.resource.ResourceResolverFactory v, v;
org.apache.sling.api.resource.ResourceResolver v;
org.slf4j.Logger v;
java.lang.RuntimeException v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
java.lang.String v, v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v = null;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.api.resource.ResourceResolverFactory resourceResolverFactory>;
if v == null goto label;
label:
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.api.resource.ResourceResolverFactory resourceResolverFactory>;
v = interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolverFactory: org.apache.sling.api.resource.ResourceResolver getServiceResourceResolver(java.util.Map)>(null);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger logger>;
v = virtualinvoke v.<org.apache.sling.api.resource.LoginException: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Unable to create new resource resolver: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>(v, v);
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
return v;
catch org.apache.sling.api.resource.LoginException from label to label with label;
}
public org.apache.sling.event.impl.jobs.config.TopologyCapabilities getTopologyCapabilities()
{
org.apache.sling.event.impl.jobs.config.TopologyCapabilities v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.event.impl.jobs.config.TopologyCapabilities topologyCapabilities>;
return v;
}
public org.apache.sling.event.impl.jobs.config.QueueConfigurationManager getQueueConfigurationManager()
{
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
org.apache.sling.event.impl.jobs.config.QueueConfigurationManager v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.event.impl.jobs.config.QueueConfigurationManager queueConfigManager>;
return v;
}
public org.slf4j.Logger getMainLogger()
{
org.slf4j.Logger v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger logger>;
return v;
}
public java.lang.String getAssginedJobsPath()
{
java.lang.String v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String assignedJobsPath>;
return v;
}
public java.lang.String getUnassignedJobsPath()
{
java.lang.String v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String unassignedJobsPath>;
return v;
}
public java.lang.String getLocalJobsPath()
{
java.lang.String v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String localJobsPath>;
return v;
}
public java.lang.String getUniquePath(java.lang.String, java.lang.String, java.lang.String, java.util.Map)
{
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
java.util.Map v;
java.lang.StringBuilder v;
java.lang.String v, v, v, v, v, v, v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.util.Map;
v = virtualinvoke v.<java.lang.String: java.lang.String replace(char,char)>(47, 46);
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
if v == null goto label;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String assignedJobsPath>;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(47);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
goto label;
label:
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String unassignedJobsPath>;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(47);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(47);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
public java.lang.String getUniqueId(java.lang.String)
{
long v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
java.util.concurrent.atomic.AtomicLong v;
java.util.Calendar v;
int v, v, v, v, v, v;
java.lang.StringBuilder v;
java.lang.String v, v, v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v := @parameter: java.lang.String;
v = staticinvoke <java.util.Calendar: java.util.Calendar getInstance()>();
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = virtualinvoke v.<java.util.Calendar: int get(int)>(1);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(int)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(47);
v = virtualinvoke v.<java.util.Calendar: int get(int)>(2);
v = v + 1;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(int)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(47);
v = virtualinvoke v.<java.util.Calendar: int get(int)>(5);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(int)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(47);
v = virtualinvoke v.<java.util.Calendar: int get(int)>(11);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(int)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(47);
v = virtualinvoke v.<java.util.Calendar: int get(int)>(12);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(int)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(47);
v = <org.apache.sling.event.impl.support.Environment: java.lang.String APPLICATION_ID>;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(95);
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.concurrent.atomic.AtomicLong jobCounter>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long getAndIncrement()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(long)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
public boolean isLocalJob(java.lang.String)
{
java.lang.String v, v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
boolean v, v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v := @parameter: java.lang.String;
if v == null goto label;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String localJobsPathWithSlash>;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>(v);
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean isJob(java.lang.String)
{
java.lang.String v, v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
boolean v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v := @parameter: java.lang.String;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String jobsBasePathWithSlash>;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>(v);
return v;
}
public java.lang.String getJobsBasePathWithSlash()
{
java.lang.String v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String jobsBasePathWithSlash>;
return v;
}
public java.lang.String getPreviousVersionAnonPath()
{
java.lang.String v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String previousVersionAnonPath>;
return v;
}
public java.lang.String getPreviousVersionIdentifiedPath()
{
java.lang.String v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String previousVersionIdentifiedPath>;
return v;
}
public boolean disableDistribution()
{
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
boolean v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: boolean disabledDistribution>;
return v;
}
public java.lang.String getStoredCancelledJobsPath()
{
java.lang.String v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String storedCancelledJobsPath>;
return v;
}
public java.lang.String getStoredSuccessfulJobsPath()
{
java.lang.String v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String storedSuccessfulJobsPath>;
return v;
}
public java.lang.String getStoragePath(java.lang.String, java.lang.String, boolean)
{
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
java.lang.StringBuilder v;
java.lang.String v, v, v, v, v, v;
boolean v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v = virtualinvoke v.<java.lang.String: java.lang.String replace(char,char)>(47, 46);
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
if v == 0 goto label;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String storedSuccessfulJobsPath>;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
goto label;
label:
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String storedCancelledJobsPath>;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(47);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(47);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
public boolean isStoragePath(java.lang.String)
{
java.lang.String v, v, v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
boolean v, v, v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v := @parameter: java.lang.String;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String storedCancelledJobsPath>;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>(v);
if v != 0 goto label;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String storedSuccessfulJobsPath>;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>(v);
if v == 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public java.lang.String getScheduledJobsPath(boolean)
{
java.lang.String v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
boolean v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v := @parameter: boolean;
if v == 0 goto label;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String scheduledJobsPathWithSlash>;
goto label;
label:
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String scheduledJobsPath>;
label:
return v;
}
private void stopProcessing()
{
org.slf4j.Logger v, v;
org.apache.sling.event.impl.jobs.config.TopologyCapabilities v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Stopping job processing...");
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.event.impl.jobs.config.TopologyCapabilities topologyCapabilities>;
if v == null goto label;
virtualinvoke v.<org.apache.sling.event.impl.jobs.config.TopologyCapabilities: void deactivate()>();
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.event.impl.jobs.config.TopologyCapabilities topologyCapabilities> = null;
specialinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: void notifyListeners()>();
label:
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Job processing stopped");
return;
}
private void startProcessing(org.apache.sling.discovery.TopologyEvent$Type, org.apache.sling.event.impl.jobs.config.TopologyCapabilities)
{
org.apache.sling.discovery.TopologyEvent$Type v, v;
org.slf4j.Logger v, v;
org.apache.sling.event.impl.jobs.tasks.CheckTopologyTask v;
java.util.Timer v;
long v, v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
org.apache.sling.event.impl.jobs.tasks.UpgradeTask v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$2 v;
org.apache.sling.event.impl.jobs.config.TopologyCapabilities v;
org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v := @parameter: org.apache.sling.discovery.TopologyEvent$Type;
v := @parameter: org.apache.sling.event.impl.jobs.config.TopologyCapabilities;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Starting job processing...");
v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.event.impl.jobs.config.TopologyCapabilities topologyCapabilities> = v;
v = <org.apache.sling.discovery.TopologyEvent$Type: org.apache.sling.discovery.TopologyEvent$Type TOPOLOGY_INIT>;
if v != v goto label;
v = new org.apache.sling.event.impl.jobs.tasks.UpgradeTask;
specialinvoke v.<org.apache.sling.event.impl.jobs.tasks.UpgradeTask: void <init>(org.apache.sling.event.impl.jobs.config.JobManagerConfiguration)>(v);
virtualinvoke v.<org.apache.sling.event.impl.jobs.tasks.UpgradeTask: void run()>();
v = new org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask;
specialinvoke v.<org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask: void <init>(org.apache.sling.event.impl.jobs.config.JobManagerConfiguration)>(v);
virtualinvoke v.<org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask: void run()>();
v = new org.apache.sling.event.impl.jobs.tasks.CheckTopologyTask;
specialinvoke v.<org.apache.sling.event.impl.jobs.tasks.CheckTopologyTask: void <init>(org.apache.sling.event.impl.jobs.config.JobManagerConfiguration)>(v);
virtualinvoke v.<org.apache.sling.event.impl.jobs.tasks.CheckTopologyTask: void fullRun()>();
specialinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: void notifyListeners()>();
goto label;
label:
v = new java.util.Timer;
specialinvoke v.<java.util.Timer: void <init>()>();
v = new org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$2;
specialinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration$2: void <init>(org.apache.sling.event.impl.jobs.config.JobManagerConfiguration,org.apache.sling.event.impl.jobs.config.TopologyCapabilities)>(v, v);
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: long backgroundLoadDelay>;
v = v * 1000L;
virtualinvoke v.<java.util.Timer: void schedule(java.util.TimerTask,long)>(v, v);
label:
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Job processing started");
return;
}
private void notifyListeners()
{
java.lang.Throwable v;
java.util.Iterator v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
java.util.List v, v;
org.apache.sling.event.impl.jobs.config.TopologyCapabilities v;
java.lang.Object v;
boolean v, v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.List listeners>;
entermonitor v;
label:
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.event.impl.jobs.config.TopologyCapabilities topologyCapabilities>;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.List listeners>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
interfaceinvoke v.<org.apache.sling.event.impl.jobs.config.ConfigurationChangeListener: void configurationChanged(boolean)>(v);
goto label;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void handleTopologyEvent(org.apache.sling.discovery.TopologyEvent)
{
org.slf4j.Logger v;
org.apache.sling.event.impl.discovery.InitDelayingTopologyEventListener v, v;
org.apache.sling.discovery.TopologyEvent v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v := @parameter: org.apache.sling.discovery.TopologyEvent;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.event.impl.discovery.InitDelayingTopologyEventListener startupDelayListener>;
if v == null goto label;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.event.impl.discovery.InitDelayingTopologyEventListener startupDelayListener>;
virtualinvoke v.<org.apache.sling.event.impl.discovery.InitDelayingTopologyEventListener: void handleTopologyEvent(org.apache.sling.discovery.TopologyEvent)>(v);
goto label;
label:
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Received topology event {}", v);
virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: void doHandleTopologyEvent(org.apache.sling.discovery.TopologyEvent)>(v);
label:
return;
}
void doHandleTopologyEvent(org.apache.sling.discovery.TopologyEvent)
{
org.apache.sling.discovery.TopologyView v, v;
java.util.Map v;
org.apache.sling.event.impl.jobs.config.TopologyCapabilities v, v, v;
org.apache.sling.discovery.TopologyEvent v;
boolean v, v;
org.apache.sling.discovery.TopologyEvent$Type v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v := @parameter: org.apache.sling.discovery.TopologyEvent;
v = 1;
v = virtualinvoke v.<org.apache.sling.discovery.TopologyEvent: org.apache.sling.discovery.TopologyEvent$Type getType()>();
v = <org.apache.sling.discovery.TopologyEvent$Type: org.apache.sling.discovery.TopologyEvent$Type PROPERTIES_CHANGED>;
if v != v goto label;
v = virtualinvoke v.<org.apache.sling.discovery.TopologyEvent: org.apache.sling.discovery.TopologyView getNewView()>();
v = staticinvoke <org.apache.sling.event.impl.jobs.config.TopologyCapabilities: java.util.Map getAllInstancesMap(org.apache.sling.discovery.TopologyView)>(v);
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.event.impl.jobs.config.TopologyCapabilities topologyCapabilities>;
if v == null goto label;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.event.impl.jobs.config.TopologyCapabilities topologyCapabilities>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.TopologyCapabilities: boolean isSame(java.util.Map)>(v);
if v == 0 goto label;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("No changes in capabilities - updating topology capabilities with new view");
v = 0;
label:
v = virtualinvoke v.<org.apache.sling.discovery.TopologyEvent: org.apache.sling.discovery.TopologyEvent$Type getType()>();
v = <org.apache.sling.discovery.TopologyEvent$Type: org.apache.sling.discovery.TopologyEvent$Type TOPOLOGY_CHANGING>;
if v != v goto label;
specialinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: void stopProcessing()>();
goto label;
label:
v = <org.apache.sling.discovery.TopologyEvent$Type: org.apache.sling.discovery.TopologyEvent$Type TOPOLOGY_INIT>;
if v == v goto label;
v = virtualinvoke v.<org.apache.sling.discovery.TopologyEvent: org.apache.sling.discovery.TopologyEvent$Type getType()>();
v = <org.apache.sling.discovery.TopologyEvent$Type: org.apache.sling.discovery.TopologyEvent$Type TOPOLOGY_CHANGED>;
if v == v goto label;
v = virtualinvoke v.<org.apache.sling.discovery.TopologyEvent: org.apache.sling.discovery.TopologyEvent$Type getType()>();
v = <org.apache.sling.discovery.TopologyEvent$Type: org.apache.sling.discovery.TopologyEvent$Type PROPERTIES_CHANGED>;
if v != v goto label;
label:
if v == 0 goto label;
specialinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: void stopProcessing()>();
label:
v = new org.apache.sling.event.impl.jobs.config.TopologyCapabilities;
v = virtualinvoke v.<org.apache.sling.discovery.TopologyEvent: org.apache.sling.discovery.TopologyView getNewView()>();
specialinvoke v.<org.apache.sling.event.impl.jobs.config.TopologyCapabilities: void <init>(org.apache.sling.discovery.TopologyView,org.apache.sling.event.impl.jobs.config.JobManagerConfiguration)>(v, v);
specialinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: void startProcessing(org.apache.sling.discovery.TopologyEvent$Type,org.apache.sling.event.impl.jobs.config.TopologyCapabilities)>(v, v);
label:
return;
}
public void addListener(org.apache.sling.event.impl.jobs.config.ConfigurationChangeListener)
{
java.lang.Throwable v;
java.util.List v, v;
org.apache.sling.event.impl.jobs.config.TopologyCapabilities v;
org.apache.sling.event.impl.jobs.config.ConfigurationChangeListener v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
boolean v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v := @parameter: org.apache.sling.event.impl.jobs.config.ConfigurationChangeListener;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.List listeners>;
entermonitor v;
label:
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.List listeners>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.event.impl.jobs.config.TopologyCapabilities topologyCapabilities>;
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
interfaceinvoke v.<org.apache.sling.event.impl.jobs.config.ConfigurationChangeListener: void configurationChanged(boolean)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void removeListener(org.apache.sling.event.impl.jobs.config.ConfigurationChangeListener)
{
java.lang.Throwable v;
java.util.List v, v;
org.apache.sling.event.impl.jobs.config.ConfigurationChangeListener v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v := @parameter: org.apache.sling.event.impl.jobs.config.ConfigurationChangeListener;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.List listeners>;
entermonitor v;
label:
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.List listeners>;
interfaceinvoke v.<java.util.List: boolean remove(java.lang.Object)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void addJobToRetryList(org.apache.sling.event.jobs.Job)
{
java.lang.Throwable v;
java.util.Map v, v;
org.apache.sling.event.jobs.Job v;
java.lang.String v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v := @parameter: org.apache.sling.event.jobs.Job;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.Map retryList>;
entermonitor v;
label:
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.Map retryList>;
v = interfaceinvoke v.<org.apache.sling.event.jobs.Job: java.lang.String getId()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public java.util.List clearJobRetryList()
{
java.lang.Throwable v;
java.util.Collection v;
java.util.Map v, v, v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
java.util.ArrayList v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.Map retryList>;
entermonitor v;
label:
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.Map retryList>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.Map retryList>;
interfaceinvoke v.<java.util.Map: void clear()>();
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return v;
catch java.lang.Throwable from label to label with label;
}
public boolean removeJobFromRetryList(org.apache.sling.event.jobs.Job)
{
java.lang.Throwable v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
java.util.Map v, v;
java.lang.Object v;
org.apache.sling.event.jobs.Job v;
java.lang.String v;
boolean v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v := @parameter: org.apache.sling.event.jobs.Job;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.Map retryList>;
entermonitor v;
label:
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.Map retryList>;
v = interfaceinvoke v.<org.apache.sling.event.jobs.Job: java.lang.String getId()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public org.apache.sling.event.jobs.Job getJobFromRetryList(java.lang.String)
{
java.lang.Throwable v;
java.util.Map v, v;
java.lang.Object v;
java.lang.String v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v := @parameter: java.lang.String;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.Map retryList>;
entermonitor v;
label:
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.util.Map retryList>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public org.slf4j.Logger getAuditLogger()
{
org.slf4j.Logger v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
v = v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger auditLogger>;
return v;
}
}