public class org.apache.sling.event.impl.jobs.JobHandler extends java.lang.Object
{
private final org.apache.sling.event.impl.jobs.JobImpl job;
public volatile long started;
private volatile boolean isStopped;
private final org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration;
private final org.apache.sling.event.jobs.consumer.JobExecutor consumer;
public void <init>(org.apache.sling.event.impl.jobs.JobImpl, org.apache.sling.event.jobs.consumer.JobExecutor, org.apache.sling.event.impl.jobs.config.JobManagerConfiguration)
{
org.apache.sling.event.jobs.consumer.JobExecutor v;
org.apache.sling.event.impl.jobs.JobHandler v;
org.apache.sling.event.impl.jobs.JobImpl v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.JobHandler;
v := @parameter: org.apache.sling.event.impl.jobs.JobImpl;
v := @parameter: org.apache.sling.event.jobs.consumer.JobExecutor;
v := @parameter: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.sling.event.impl.jobs.JobHandler: long started> = -1L;
v.<org.apache.sling.event.impl.jobs.JobHandler: boolean isStopped> = 0;
v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job> = v;
v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.jobs.consumer.JobExecutor consumer> = v;
v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration> = v;
return;
}
public org.apache.sling.event.impl.jobs.JobImpl getJob()
{
org.apache.sling.event.impl.jobs.JobHandler v;
org.apache.sling.event.impl.jobs.JobImpl v;
v := @this: org.apache.sling.event.impl.jobs.JobHandler;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
return v;
}
public org.apache.sling.event.jobs.consumer.JobExecutor getConsumer()
{
org.apache.sling.event.impl.jobs.JobHandler v;
org.apache.sling.event.jobs.consumer.JobExecutor v;
v := @this: org.apache.sling.event.impl.jobs.JobHandler;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.jobs.consumer.JobExecutor consumer>;
return v;
}
public boolean startProcessing(org.apache.sling.event.jobs.Queue)
{
org.apache.sling.event.impl.jobs.JobHandler v;
java.lang.String[] v;
org.apache.sling.event.impl.jobs.JobImpl v;
org.apache.sling.event.jobs.Queue v;
boolean v;
v := @this: org.apache.sling.event.impl.jobs.JobHandler;
v := @parameter: org.apache.sling.event.jobs.Queue;
v.<org.apache.sling.event.impl.jobs.JobHandler: boolean isStopped> = 0;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String[] prepare(org.apache.sling.event.jobs.Queue)>(v);
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobHandler: boolean persistJobProperties(java.lang.String[])>(v);
return v;
}
public boolean reschedule()
{
java.lang.Throwable v, v;
org.apache.sling.api.resource.ResourceResolver v;
java.util.Calendar v;
java.lang.String v, v, v;
org.slf4j.Logger 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;
java.lang.Object v, v, v, v;
org.apache.sling.event.impl.jobs.JobImpl v, v, v, v, v;
v := @this: org.apache.sling.event.impl.jobs.JobHandler;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.api.resource.ResourceResolver createResourceResolver()>();
label:
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String getResourcePath()>();
v = interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: org.apache.sling.api.resource.Resource getResource(java.lang.String)>(v);
if v == null goto label;
v = interfaceinvoke v.<org.apache.sling.api.resource.Resource: java.lang.Object adaptTo(java.lang.Class)>(class "Lorg/apache/sling/api/resource/ModifiableValueMap;");
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.Object getProperty(java.lang.String,java.lang.Class)>("event.job.retrycount", class "Ljava/lang/Integer;");
interfaceinvoke v.<org.apache.sling.api.resource.ModifiableValueMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("event.job.retrycount", v);
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.Object getProperty(java.lang.String)>("slingevent:resultMessage");
if v == null goto label;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.Object getProperty(java.lang.String)>("slingevent:resultMessage");
interfaceinvoke v.<org.apache.sling.api.resource.ModifiableValueMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("slingevent:resultMessage", v);
label:
interfaceinvoke v.<org.apache.sling.api.resource.ModifiableValueMap: java.lang.Object remove(java.lang.Object)>("event.job.started.time");
v = staticinvoke <java.util.Calendar: java.util.Calendar getInstance()>();
interfaceinvoke v.<org.apache.sling.api.resource.ModifiableValueMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("event.job.queued.time", v);
label:
interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: void commit()>();
label:
interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: void close()>();
return 1;
label:
v := @caughtexception;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger getMainLogger()>();
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String getId()>();
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 update reschedule properties for job \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Throwable)>(v, v);
label:
interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: void close()>();
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: void close()>();
throw v;
label:
return 0;
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 void finished(org.apache.sling.event.jobs.Job$JobState, boolean, java.lang.Long)
{
org.apache.sling.api.resource.ValueMap v;
org.apache.sling.api.resource.ResourceResolver v;
java.util.Date v, v;
java.lang.Long v;
java.lang.InstantiationException v;
boolean v, v, v, v;
java.lang.Throwable v, v;
java.util.HashMap v;
long v, v, v;
java.util.Calendar v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v, v, v, v, v;
org.apache.sling.event.jobs.Job$JobState v, 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, v;
java.lang.Object v, v;
org.apache.sling.event.impl.jobs.JobImpl v, v, v, v, v, v, v, v, v;
v := @this: org.apache.sling.event.impl.jobs.JobHandler;
v := @parameter: org.apache.sling.event.jobs.Job$JobState;
v := @parameter: boolean;
v := @parameter: java.lang.Long;
v = <org.apache.sling.event.jobs.Job$JobState: org.apache.sling.event.jobs.Job$JobState SUCCEEDED>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.api.resource.ResourceResolver createResourceResolver()>();
label:
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String getResourcePath()>();
v = interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: org.apache.sling.api.resource.Resource getResource(java.lang.String)>(v);
if v == null goto label;
label:
v = null;
if v == 0 goto label;
v = staticinvoke <org.apache.sling.event.impl.support.ResourceHelper: org.apache.sling.api.resource.ValueMap getValueMap(org.apache.sling.api.resource.Resource)>(v);
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String getTopic()>();
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String getId()>();
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String getStoragePath(java.lang.String,java.lang.String,boolean)>(v, v, v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
v = virtualinvoke v.<org.apache.sling.event.jobs.Job$JobState: java.lang.String name()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("slingevent:finishedState", v);
if v == 0 goto label;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>()>();
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.util.Calendar getProcessingStarted()>();
v = virtualinvoke v.<java.util.Calendar: java.util.Date getTime()>();
v = virtualinvoke v.<java.util.Date: long getTime()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v + v;
virtualinvoke v.<java.util.Date: void setTime(long)>(v);
v = staticinvoke <java.util.Calendar: java.util.Calendar getInstance()>();
virtualinvoke v.<java.util.Calendar: void setTime(java.util.Date)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("slingevent:finishedDate", v);
goto label;
label:
v = staticinvoke <java.util.Calendar: java.util.Calendar getInstance()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("slingevent:finishedDate", v);
label:
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.Object getProperty(java.lang.String)>("slingevent:resultMessage");
if v == null goto label;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.Object getProperty(java.lang.String)>("slingevent:resultMessage");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("slingevent:resultMessage", v);
label:
staticinvoke <org.apache.sling.event.impl.support.ResourceHelper: org.apache.sling.api.resource.Resource getOrCreateResource(org.apache.sling.api.resource.ResourceResolver,java.lang.String,java.util.Map)>(v, v, v);
label:
interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: void delete(org.apache.sling.api.resource.Resource)>(v);
interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: void commit()>();
if v == 0 goto label;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger getMainLogger()>();
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
if v == 0 goto label;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger getMainLogger()>();
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = staticinvoke <org.apache.sling.event.impl.jobs.Utility: java.lang.String toString(org.apache.sling.event.jobs.Job)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("Kept successful job {} at {}", v, v);
goto label;
label:
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger getMainLogger()>();
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = staticinvoke <org.apache.sling.event.impl.jobs.Utility: java.lang.String toString(org.apache.sling.event.jobs.Job)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("Moved cancelled job {} to {}", v, v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger getMainLogger()>();
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String getId()>();
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 finish job \u0001");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>(v, v);
goto label;
label:
v := @caughtexception;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger getMainLogger()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Throwable)>("Unable to instantiate job", v);
label:
interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: void close()>();
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: void close()>();
throw v;
label:
return;
catch org.apache.sling.api.resource.PersistenceException from label to label with label;
catch java.lang.InstantiationException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void reassign()
{
org.apache.sling.api.resource.ValueMap v;
org.apache.sling.api.resource.ResourceResolver v;
java.util.Map v, v;
java.lang.InstantiationException v;
java.lang.Throwable v, v;
java.util.HashMap 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;
org.slf4j.Logger v, 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;
org.apache.sling.event.impl.jobs.config.QueueConfigurationManager v;
org.apache.sling.event.impl.jobs.JobImpl v, v, v, v, v, v, v, v;
v := @this: org.apache.sling.event.impl.jobs.JobHandler;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.event.impl.jobs.config.QueueConfigurationManager getQueueConfigurationManager()>();
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String getTopic()>();
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.QueueConfigurationManager: org.apache.sling.event.impl.jobs.config.QueueConfigurationManager$QueueInfo getQueueInfo(java.lang.String)>(v);
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.event.impl.jobs.config.TopologyCapabilities getTopologyCapabilities()>();
if v != null goto label;
v = null;
goto label;
label:
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String getTopic()>();
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.util.Map getProperties()>();
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.TopologyCapabilities: java.lang.String detectTarget(java.lang.String,java.util.Map,org.apache.sling.event.impl.jobs.config.QueueConfigurationManager$QueueInfo)>(v, v, v);
label:
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.api.resource.ResourceResolver createResourceResolver()>();
label:
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String getResourcePath()>();
v = interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: org.apache.sling.api.resource.Resource getResource(java.lang.String)>(v);
if v == null goto label;
label:
v = staticinvoke <org.apache.sling.event.impl.support.ResourceHelper: org.apache.sling.api.resource.ValueMap getValueMap(org.apache.sling.api.resource.Resource)>(v);
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String getTopic()>();
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String getId()>();
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.util.Map getProperties()>();
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String getUniquePath(java.lang.String,java.lang.String,java.lang.String,java.util.Map)>(v, v, v, v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>("event.job.queuename");
if v != null goto label;
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>("event.job.application");
goto label;
label:
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("event.job.application", v);
label:
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>("event.job.started.time");
label:
staticinvoke <org.apache.sling.event.impl.support.ResourceHelper: org.apache.sling.api.resource.Resource getOrCreateResource(org.apache.sling.api.resource.ResourceResolver,java.lang.String,java.util.Map)>(v, v, v);
interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: void delete(org.apache.sling.api.resource.Resource)>(v);
interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: void commit()>();
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger getMainLogger()>();
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String getId()>();
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 reassign job \u0001");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger getMainLogger()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Throwable)>("Unable to instantiate job", v);
label:
interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: void close()>();
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: void close()>();
throw v;
label:
return;
catch org.apache.sling.api.resource.PersistenceException from label to label with label;
catch java.lang.InstantiationException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public transient boolean persistJobProperties(java.lang.String[])
{
java.lang.Throwable v, v;
org.apache.sling.api.resource.ResourceResolver v;
java.lang.String[] v;
int v, v;
java.lang.String v, v, v, v;
boolean v;
org.slf4j.Logger v, 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;
java.lang.Class v;
java.lang.Object v, v;
org.apache.sling.event.impl.jobs.JobImpl v, v, v;
v := @this: org.apache.sling.event.impl.jobs.JobHandler;
v := @parameter: java.lang.String[];
if v == null goto label;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.api.resource.ResourceResolver createResourceResolver()>();
label:
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String getResourcePath()>();
v = interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: org.apache.sling.api.resource.Resource getResource(java.lang.String)>(v);
if v == null goto label;
v = interfaceinvoke v.<org.apache.sling.api.resource.Resource: java.lang.Object adaptTo(java.lang.Class)>(class "Lorg/apache/sling/api/resource/ModifiableValueMap;");
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.Object getProperty(java.lang.String)>(v);
if v == null goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: boolean isEnum()>();
if v == 0 goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
interfaceinvoke v.<org.apache.sling.api.resource.ModifiableValueMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
interfaceinvoke v.<org.apache.sling.api.resource.ModifiableValueMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
interfaceinvoke v.<org.apache.sling.api.resource.ModifiableValueMap: java.lang.Object remove(java.lang.Object)>(v);
label:
v = v + 1;
goto label;
label:
interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: void commit()>();
label:
interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: void close()>();
return 1;
label:
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger getMainLogger()>();
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String getResourcePath()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("No job resource found at {}", 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.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.slf4j.Logger getMainLogger()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Throwable)>("Unable to persist properties", v);
label:
interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: void close()>();
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: void close()>();
throw v;
label:
return 0;
label:
return 1;
catch org.apache.sling.api.resource.PersistenceException from label to label with label;
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;
catch java.lang.Throwable from label to label with label;
}
public boolean isStopped()
{
org.apache.sling.event.impl.jobs.JobHandler v;
boolean v;
v := @this: org.apache.sling.event.impl.jobs.JobHandler;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: boolean isStopped>;
return v;
}
public void stop()
{
org.apache.sling.event.impl.jobs.JobHandler v;
v := @this: org.apache.sling.event.impl.jobs.JobHandler;
v.<org.apache.sling.event.impl.jobs.JobHandler: boolean isStopped> = 1;
return;
}
public void addToRetryList()
{
org.apache.sling.event.impl.jobs.JobHandler v;
org.apache.sling.event.impl.jobs.JobImpl v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
v := @this: org.apache.sling.event.impl.jobs.JobHandler;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: void addJobToRetryList(org.apache.sling.event.jobs.Job)>(v);
return;
}
public boolean removeFromRetryList()
{
org.apache.sling.event.impl.jobs.JobHandler v;
org.apache.sling.event.impl.jobs.JobImpl v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
boolean v;
v := @this: org.apache.sling.event.impl.jobs.JobHandler;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: boolean removeJobFromRetryList(org.apache.sling.event.jobs.Job)>(v);
return v;
}
public int hashCode()
{
int v;
org.apache.sling.event.impl.jobs.JobHandler v;
org.apache.sling.event.impl.jobs.JobImpl v;
java.lang.String v;
v := @this: org.apache.sling.event.impl.jobs.JobHandler;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String getId()>();
v = virtualinvoke v.<java.lang.String: int hashCode()>();
return v;
}
public boolean equals(java.lang.Object)
{
org.apache.sling.event.impl.jobs.JobHandler v;
java.lang.Object v;
org.apache.sling.event.impl.jobs.JobImpl v, v;
java.lang.String v, v;
boolean v, v;
v := @this: org.apache.sling.event.impl.jobs.JobHandler;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.sling.event.impl.jobs.JobHandler;
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String getId()>();
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String getId()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
return v;
}
public java.lang.String toString()
{
org.apache.sling.event.impl.jobs.JobHandler v;
org.apache.sling.event.impl.jobs.JobImpl v;
java.lang.String v, v;
v := @this: org.apache.sling.event.impl.jobs.JobHandler;
v = v.<org.apache.sling.event.impl.jobs.JobHandler: org.apache.sling.event.impl.jobs.JobImpl job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String getId()>();
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[])>("JobHandler(\u)");
return v;
}
}