class org.apache.sling.event.impl.jobs.queues.JobQueueImpl$2 extends java.lang.Object implements org.apache.sling.event.impl.jobs.queues.JobExecutionContextImpl$ASyncHandler
{
final org.apache.sling.event.impl.jobs.JobImpl val$job;
final org.apache.sling.event.impl.jobs.queues.JobQueueImpl this$0;
void <init>(org.apache.sling.event.impl.jobs.queues.JobQueueImpl, org.apache.sling.event.impl.jobs.JobImpl)
{
org.apache.sling.event.impl.jobs.JobImpl v;
org.apache.sling.event.impl.jobs.queues.JobQueueImpl v;
org.apache.sling.event.impl.jobs.queues.JobQueueImpl$2 v;
v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl$2;
v := @parameter: org.apache.sling.event.impl.jobs.queues.JobQueueImpl;
v := @parameter: org.apache.sling.event.impl.jobs.JobImpl;
v.<org.apache.sling.event.impl.jobs.queues.JobQueueImpl$2: org.apache.sling.event.impl.jobs.queues.JobQueueImpl this$0> = v;
v.<org.apache.sling.event.impl.jobs.queues.JobQueueImpl$2: org.apache.sling.event.impl.jobs.JobImpl val$job> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void finished(org.apache.sling.event.jobs.Job$JobState)
{
org.apache.sling.event.jobs.Job$JobState v;
org.apache.sling.event.impl.jobs.JobConsumerManager v;
org.apache.sling.event.impl.jobs.queues.JobQueueImpl$2 v;
java.util.concurrent.atomic.AtomicInteger v;
org.apache.sling.event.impl.jobs.JobImpl v, v;
java.lang.String v, v;
org.apache.sling.event.impl.jobs.queues.JobQueueImpl v, v, v;
org.apache.sling.event.impl.jobs.queues.QueueServices v;
v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl$2;
v := @parameter: org.apache.sling.event.jobs.Job$JobState;
v = v.<org.apache.sling.event.impl.jobs.queues.JobQueueImpl$2: org.apache.sling.event.impl.jobs.queues.JobQueueImpl this$0>;
v = v.<org.apache.sling.event.impl.jobs.queues.JobQueueImpl: org.apache.sling.event.impl.jobs.queues.QueueServices services>;
v = v.<org.apache.sling.event.impl.jobs.queues.QueueServices: org.apache.sling.event.impl.jobs.JobConsumerManager jobConsumerManager>;
v = v.<org.apache.sling.event.impl.jobs.queues.JobQueueImpl$2: org.apache.sling.event.impl.jobs.JobImpl val$job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String getId()>();
virtualinvoke v.<org.apache.sling.event.impl.jobs.JobConsumerManager: void unregisterListener(java.lang.String)>(v);
v = v.<org.apache.sling.event.impl.jobs.queues.JobQueueImpl$2: org.apache.sling.event.impl.jobs.queues.JobQueueImpl this$0>;
v = v.<org.apache.sling.event.impl.jobs.queues.JobQueueImpl$2: org.apache.sling.event.impl.jobs.JobImpl val$job>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.lang.String getId()>();
specialinvoke v.<org.apache.sling.event.impl.jobs.queues.JobQueueImpl: boolean finishedJob(java.lang.String,org.apache.sling.event.jobs.Job$JobState,boolean)>(v, v, 1);
v = v.<org.apache.sling.event.impl.jobs.queues.JobQueueImpl$2: org.apache.sling.event.impl.jobs.queues.JobQueueImpl this$0>;
v = v.<org.apache.sling.event.impl.jobs.queues.JobQueueImpl: java.util.concurrent.atomic.AtomicInteger asyncCounter>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int decrementAndGet()>();
return;
}
}