public class org.apache.sling.event.impl.jobs.console.WebConsolePlugin extends javax.servlet.http.HttpServlet implements org.apache.sling.event.jobs.consumer.JobConsumer
{
private static final java.lang.String SLING_WEBCONSOLE_TEST_JOB_TOPIC;
private static final long serialVersionUID;
private final org.slf4j.Logger logger;
private org.apache.sling.event.jobs.JobManager jobManager;
private org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration;
private org.apache.sling.event.impl.jobs.JobConsumerManager jobConsumerManager;
private static final java.lang.String PAR_QUEUE;
private final java.text.DateFormat dateFormat;
public void <init>()
{
org.slf4j.Logger v;
org.apache.sling.event.impl.jobs.console.WebConsolePlugin v;
java.text.SimpleDateFormat v;
java.lang.Class v;
v := @this: org.apache.sling.event.impl.jobs.console.WebConsolePlugin;
specialinvoke v.<javax.servlet.http.HttpServlet: void <init>()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(v);
v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: org.slf4j.Logger logger> = v;
v = new java.text.SimpleDateFormat;
specialinvoke v.<java.text.SimpleDateFormat: void <init>(java.lang.String)>("HH:mm:ss:SSS yyyy-MMM-dd");
v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.text.DateFormat dateFormat> = v;
return;
}
private org.apache.sling.event.jobs.Queue getQueue(javax.servlet.http.HttpServletRequest)
{
java.util.Iterator v;
org.apache.sling.event.impl.jobs.console.WebConsolePlugin v;
java.lang.Iterable v;
javax.servlet.http.HttpServletRequest v;
org.apache.sling.event.jobs.JobManager v;
java.lang.Object v;
java.lang.String v, v;
boolean v, v;
v := @this: org.apache.sling.event.impl.jobs.console.WebConsolePlugin;
v := @parameter: javax.servlet.http.HttpServletRequest;
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getParameter(java.lang.String)>("queue");
if v == null goto label;
v = v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: org.apache.sling.event.jobs.JobManager jobManager>;
v = interfaceinvoke v.<org.apache.sling.event.jobs.JobManager: java.lang.Iterable getQueues()>();
v = interfaceinvoke v.<java.lang.Iterable: 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()>();
v = interfaceinvoke v.<org.apache.sling.event.jobs.Queue: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
return v;
label:
return null;
}
private java.lang.String getQueueErrorMessage(javax.servlet.http.HttpServletRequest, java.lang.String)
{
javax.servlet.http.HttpServletRequest v;
org.apache.sling.event.impl.jobs.console.WebConsolePlugin v;
int v;
java.lang.String v, v, v, v;
v := @this: org.apache.sling.event.impl.jobs.console.WebConsolePlugin;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: java.lang.String;
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getParameter(java.lang.String)>("queue");
if v == null goto label;
v = virtualinvoke v.<java.lang.String: int length()>();
if v != 0 goto label;
label:
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[])>("Queue parameter missing for opertation \u0001");
return v;
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("Queue with name \'\u0001\' not found for operation \u0001");
return v;
}
protected void doPost(javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse) throws javax.servlet.ServletException, java.io.IOException
{
org.apache.sling.event.jobs.Queue v, v, v, v;
boolean v, v, v, v, v;
org.apache.sling.event.jobs.Statistics v, v;
javax.servlet.http.HttpServletRequest v;
org.apache.sling.event.jobs.JobManager v;
int v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.sling.event.impl.jobs.console.WebConsolePlugin v;
javax.servlet.http.HttpServletResponse v;
v := @this: org.apache.sling.event.impl.jobs.console.WebConsolePlugin;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: javax.servlet.http.HttpServletResponse;
v = null;
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getParameter(java.lang.String)>("action");
v = "suspend";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: org.apache.sling.event.jobs.Queue getQueue(javax.servlet.http.HttpServletRequest)>(v);
if v == null goto label;
interfaceinvoke v.<org.apache.sling.event.jobs.Queue: void suspend()>();
goto label;
label:
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String getQueueErrorMessage(javax.servlet.http.HttpServletRequest,java.lang.String)>(v, "suspend");
goto label;
label:
v = "resume";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: org.apache.sling.event.jobs.Queue getQueue(javax.servlet.http.HttpServletRequest)>(v);
if v == null goto label;
interfaceinvoke v.<org.apache.sling.event.jobs.Queue: void resume()>();
goto label;
label:
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String getQueueErrorMessage(javax.servlet.http.HttpServletRequest,java.lang.String)>(v, "resume");
goto label;
label:
v = "reset";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getParameter(java.lang.String)>("queue");
if v == null goto label;
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getParameter(java.lang.String)>("queue");
v = virtualinvoke v.<java.lang.String: int length()>();
if v != 0 goto label;
label:
v = v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: org.apache.sling.event.jobs.JobManager jobManager>;
v = interfaceinvoke v.<org.apache.sling.event.jobs.JobManager: org.apache.sling.event.jobs.Statistics getStatistics()>();
interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: void reset()>();
goto label;
label:
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: org.apache.sling.event.jobs.Queue getQueue(javax.servlet.http.HttpServletRequest)>(v);
if v == null goto label;
v = interfaceinvoke v.<org.apache.sling.event.jobs.Queue: org.apache.sling.event.jobs.Statistics getStatistics()>();
interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: void reset()>();
goto label;
label:
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String getQueueErrorMessage(javax.servlet.http.HttpServletRequest,java.lang.String)>(v, "reset");
goto label;
label:
v = "test";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: void startTestJob()>();
goto label;
label:
v = "dropall";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: org.apache.sling.event.jobs.Queue getQueue(javax.servlet.http.HttpServletRequest)>(v);
if v == null goto label;
interfaceinvoke v.<org.apache.sling.event.jobs.Queue: void removeAll()>();
goto label;
label:
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String getQueueErrorMessage(javax.servlet.http.HttpServletRequest,java.lang.String)>(v, "drop all");
goto label;
label:
v = "Unknown command";
label:
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getContextPath()>();
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getServletPath()>();
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getPathInfo()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, v, 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\u0001\u0001");
if v != null goto label;
v = v;
goto label;
label:
v = staticinvoke <java.net.URLEncoder: java.lang.String encode(java.lang.String,java.lang.String)>(v, "UTF-8");
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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?message=\u0001");
label:
v = interfaceinvoke v.<javax.servlet.http.HttpServletResponse: java.lang.String encodeRedirectURL(java.lang.String)>(v);
interfaceinvoke v.<javax.servlet.http.HttpServletResponse: void sendRedirect(java.lang.String)>(v);
return;
}
private void startTestJob()
{
org.apache.sling.event.jobs.JobManager v;
org.slf4j.Logger v;
org.apache.sling.event.impl.jobs.console.WebConsolePlugin v;
v := @this: org.apache.sling.event.impl.jobs.console.WebConsolePlugin;
v = v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Adding test job: {}", "sling/webconsole/test");
v = v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: org.apache.sling.event.jobs.JobManager jobManager>;
interfaceinvoke v.<org.apache.sling.event.jobs.JobManager: org.apache.sling.event.jobs.Job addJob(java.lang.String,java.util.Map)>("sling/webconsole/test", null);
return;
}
protected void doGet(javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse) throws javax.servlet.ServletException, java.io.IOException
{
java.lang.Integer v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Long v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.Map v;
java.lang.StringBuilder v, v;
java.lang.Object[] 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, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
long 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, v, v, v, v, v, v;
org.apache.sling.event.jobs.Statistics v, v;
org.apache.sling.event.impl.jobs.JobConsumerManager v;
org.apache.sling.event.impl.jobs.config.TopologyCapabilities v;
org.apache.sling.event.jobs.QueueConfiguration$Type v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v, v, v;
java.util.Date v;
int[] v;
java.util.Collection v, v;
org.apache.sling.event.jobs.QueueConfiguration$ThreadPriority v;
org.apache.sling.event.jobs.QueueConfiguration v;
int 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.apache.sling.event.impl.jobs.config.InternalQueueConfiguration[] v;
java.lang.Object v, v, v, v, v, v, v, v;
org.apache.sling.event.jobs.ScheduleInfo$ScheduleType v;
org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration v, v;
java.io.PrintWriter v;
java.util.Set v;
javax.servlet.http.HttpServletRequest v;
org.apache.sling.event.jobs.JobManager v, v, v, 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, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.sling.event.impl.jobs.console.WebConsolePlugin v;
boolean v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String[] v, v;
java.lang.Iterable v, v;
java.util.Iterator v, v, v, v, v, v;
javax.servlet.http.HttpServletResponse v;
org.apache.sling.event.impl.jobs.config.QueueConfigurationManager v, v;
v := @this: org.apache.sling.event.impl.jobs.console.WebConsolePlugin;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: javax.servlet.http.HttpServletResponse;
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getParameter(java.lang.String)>("message");
v = interfaceinvoke v.<javax.servlet.http.HttpServletResponse: java.io.PrintWriter getWriter()>();
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<form method=\'POST\' name=\'eventingcmd\'><input type=\'hidden\' name=\'action\' value=\'\'/><input type=\'hidden\' name=\'queue\' value=\'\'/></form>");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<script type=\'text/javascript\'>");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("function eventingsubmit(action, queue) { document.forms[\'eventingcmd\'].action.value = action; document.forms[\'eventingcmd\'].queue.value = queue; document.forms[\'eventingcmd\'].submit();} </script>");
v = newarray (java.lang.Object)[1];
if v == null goto label;
v = staticinvoke <org.apache.sling.api.request.ResponseUtil: java.lang.String escapeXml(java.lang.String)>(v);
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");
goto label;
label:
v = "";
label:
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<p class=\'statline ui-state-highlight\'>Apache Sling Job Handling%s%n</p>", v);
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<div class=\'ui-widget-header ui-corner-top buttonGroup\'>");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<span style=\'float: left; margin-left: 1em\'>Apache Sling Job Handling: Overall Statistics</span>");
specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: void printForm(java.io.PrintWriter,java.lang.String,java.lang.String,java.lang.String)>(v, null, "Reset Stats", "reset");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("</div>");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<table class=\'nicetable\'><tbody>");
v = v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: org.apache.sling.event.impl.jobs.JobConsumerManager jobConsumerManager>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobConsumerManager: java.lang.String getTopics()>();
if v != null goto label;
v = "";
goto label;
label:
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(",");
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = 1;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
if v == 0 goto label;
v = 0;
goto label;
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("<br/>");
label:
v = staticinvoke <org.apache.sling.api.request.ResponseUtil: java.lang.String escapeXml(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = v + 1;
goto label;
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
label:
v = v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: org.apache.sling.event.jobs.JobManager jobManager>;
v = interfaceinvoke v.<org.apache.sling.event.jobs.JobManager: org.apache.sling.event.jobs.Statistics getStatistics()>();
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getStartTime()>();
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String formatDate(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Start Time</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Local topic consumers: </td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getLastActivatedJobTime()>();
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String formatDate(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Last Activated</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getLastFinishedJobTime()>();
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String formatDate(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Last Finished</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getNumberOfQueuedJobs()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Queued Jobs</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getNumberOfActiveJobs()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Active Jobs</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getNumberOfJobs()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Jobs</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getNumberOfFinishedJobs()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Finished Jobs</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getNumberOfFailedJobs()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Failed Jobs</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getNumberOfCancelledJobs()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Cancelled Jobs</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getNumberOfProcessedJobs()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Processed Jobs</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getAverageProcessingTime()>();
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String formatTime(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Average Processing Time</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getAverageWaitingTime()>();
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String formatTime(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Average Waiting Time</td><td>%s</td></tr>", v);
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("</tbody></table>");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<br/>");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<table class=\'nicetable\'><tbody>");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<tr><th colspan=\'2\'>Topology Capabilities</th></tr>");
v = v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: 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;
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>("<tr><td colspan=\'2\'>No topology information available !</td></tr>");
goto label;
label:
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.TopologyCapabilities: java.util.Map getInstanceCapabilities()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: 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()>();
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
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()>();
v = virtualinvoke v.<java.lang.StringBuilder: int length()>();
if v <= 0 goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("<br/>");
label:
v = interfaceinvoke v.<org.apache.sling.discovery.InstanceDescription: boolean isLocal()>();
if v == 0 goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("<b>local</b>");
goto label;
label:
v = interfaceinvoke v.<org.apache.sling.discovery.InstanceDescription: java.lang.String getSlingId()>();
v = staticinvoke <org.apache.sling.api.request.ResponseUtil: java.lang.String escapeXml(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
goto label;
label:
v = newarray (java.lang.Object)[2];
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = staticinvoke <org.apache.sling.api.request.ResponseUtil: java.lang.String escapeXml(java.lang.String)>(v);
v[0] = v;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
v[1] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>%s</td><td>%s</td></tr>", v);
goto label;
label:
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("</tbody></table>");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<br/>");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<p class=\'statline\'>Scheduled Jobs</p>");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<table class=\'nicetable\'><tbody>");
v = v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: org.apache.sling.event.jobs.JobManager jobManager>;
v = interfaceinvoke v.<org.apache.sling.event.jobs.JobManager: java.util.Collection getScheduledJobs()>();
v = interfaceinvoke v.<java.util.Collection: int size()>();
if v != 0 goto label;
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>("<tr><td colspan=\'5\'>No jobs currently scheduled.</td></tr>");
goto label;
label:
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<tr><th>Schedule</th><th>Job Topic</th><th>Schedules</th></tr>");
v = 1;
v = interfaceinvoke v.<java.util.Collection: 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()>();
v = newarray (java.lang.Object)[2];
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
v[0] = v;
v = interfaceinvoke v.<org.apache.sling.event.jobs.ScheduledJobInfo: java.lang.String getJobTopic()>();
v = staticinvoke <org.apache.sling.api.request.ResponseUtil: java.lang.String escapeXml(java.lang.String)>(v);
v[1] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td><b>%s</b></td><td>%s</td><td>", v);
v = 1;
v = interfaceinvoke v.<org.apache.sling.event.jobs.ScheduledJobInfo: java.util.Collection getSchedules()>();
v = interfaceinvoke v.<java.util.Collection: 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 != 0 goto label;
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>("<br/>");
label:
v = 0;
v = <org.apache.sling.event.impl.jobs.console.WebConsolePlugin$1: int[] $SwitchMap$org$apache$sling$event$jobs$ScheduleInfo$ScheduleType>;
v = interfaceinvoke v.<org.apache.sling.event.jobs.ScheduleInfo: org.apache.sling.event.jobs.ScheduleInfo$ScheduleType getType()>();
v = virtualinvoke v.<org.apache.sling.event.jobs.ScheduleInfo$ScheduleType: int ordinal()>();
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;
case 6: goto label;
default: goto label;
};
label:
v = newarray (java.lang.Object)[4];
v = interfaceinvoke v.<org.apache.sling.event.jobs.ScheduleInfo: int getMonthOfYear()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = interfaceinvoke v.<org.apache.sling.event.jobs.ScheduleInfo: int getDayOfMonth()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = interfaceinvoke v.<org.apache.sling.event.jobs.ScheduleInfo: int getHourOfDay()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
v = interfaceinvoke v.<org.apache.sling.event.jobs.ScheduleInfo: int getMinuteOfHour()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[3] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("YEARLY %s %s : %s:%s", v);
goto label;
label:
v = newarray (java.lang.Object)[3];
v = interfaceinvoke v.<org.apache.sling.event.jobs.ScheduleInfo: int getDayOfMonth()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = interfaceinvoke v.<org.apache.sling.event.jobs.ScheduleInfo: int getHourOfDay()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = interfaceinvoke v.<org.apache.sling.event.jobs.ScheduleInfo: int getMinuteOfHour()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("MONTHLY %s : %s:%s", v);
goto label;
label:
v = newarray (java.lang.Object)[3];
v = interfaceinvoke v.<org.apache.sling.event.jobs.ScheduleInfo: int getDayOfWeek()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = interfaceinvoke v.<org.apache.sling.event.jobs.ScheduleInfo: int getHourOfDay()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = interfaceinvoke v.<org.apache.sling.event.jobs.ScheduleInfo: int getMinuteOfHour()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("WEEKLY %s : %s:%s", v);
goto label;
label:
v = newarray (java.lang.Object)[2];
v = interfaceinvoke v.<org.apache.sling.event.jobs.ScheduleInfo: int getHourOfDay()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = interfaceinvoke v.<org.apache.sling.event.jobs.ScheduleInfo: int getMinuteOfHour()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("DAILY %s:%s", v);
goto label;
label:
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.ScheduleInfo: int getMinuteOfHour()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("HOURLY %s", v);
goto label;
label:
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.ScheduleInfo: java.lang.String getExpression()>();
v = staticinvoke <org.apache.sling.api.request.ResponseUtil: java.lang.String escapeXml(java.lang.String)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("CRON %s", v);
goto label;
label:
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.ScheduleInfo: java.util.Date getAt()>();
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("AT %s", v);
goto label;
label:
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>("</td></tr>");
v = v + 1;
goto label;
label:
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("</tbody></table>");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<br/>");
v = 1;
v = v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: org.apache.sling.event.jobs.JobManager jobManager>;
v = interfaceinvoke v.<org.apache.sling.event.jobs.JobManager: java.lang.Iterable getQueues()>();
v = interfaceinvoke v.<java.lang.Iterable: 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()>();
v = 0;
v = interfaceinvoke v.<org.apache.sling.event.jobs.Queue: java.lang.String getName()>();
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<div class=\'ui-widget-header ui-corner-top buttonGroup\'>");
v = newarray (java.lang.Object)[2];
v = staticinvoke <org.apache.sling.api.request.ResponseUtil: java.lang.String escapeXml(java.lang.String)>(v);
v[0] = v;
v = interfaceinvoke v.<org.apache.sling.event.jobs.Queue: boolean isSuspended()>();
if v == 0 goto label;
v = "(SUSPENDED)";
goto label;
label:
v = "";
label:
v[1] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<span style=\'float: left; margin-left: 1em\'>Active JobQueue: %s %s</span>", v);
specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: void printForm(java.io.PrintWriter,java.lang.String,java.lang.String,java.lang.String)>(v, v, "Reset Stats", "reset");
v = interfaceinvoke v.<org.apache.sling.event.jobs.Queue: boolean isSuspended()>();
if v == 0 goto label;
specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: void printForm(java.io.PrintWriter,java.lang.String,java.lang.String,java.lang.String)>(v, v, "Resume", "resume");
goto label;
label:
specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: void printForm(java.io.PrintWriter,java.lang.String,java.lang.String,java.lang.String)>(v, v, "Suspend", "suspend");
label:
specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: void printForm(java.io.PrintWriter,java.lang.String,java.lang.String,java.lang.String)>(v, v, "Test", "test");
specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: void printForm(java.io.PrintWriter,java.lang.String,java.lang.String,java.lang.String)>(v, v, "Drop All", "dropall");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("</div>");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<table class=\'nicetable\'><tbody>");
v = interfaceinvoke v.<org.apache.sling.event.jobs.Queue: org.apache.sling.event.jobs.Statistics getStatistics()>();
v = interfaceinvoke v.<org.apache.sling.event.jobs.Queue: org.apache.sling.event.jobs.QueueConfiguration getConfiguration()>();
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<tr><th colspan=\'2\'>Statistics</th><th colspan=\'2\'>Configuration</th></tr>");
v = newarray (java.lang.Object)[2];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getStartTime()>();
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String formatDate(long)>(v);
v[0] = v;
v = interfaceinvoke v.<org.apache.sling.event.jobs.QueueConfiguration: org.apache.sling.event.jobs.QueueConfiguration$Type getType()>();
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String formatType(org.apache.sling.event.jobs.QueueConfiguration$Type)>(v);
v[1] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Start Time</td><td>%s</td><td>Type</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[2];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getLastActivatedJobTime()>();
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String formatDate(long)>(v);
v[0] = v;
v = interfaceinvoke v.<org.apache.sling.event.jobs.QueueConfiguration: java.lang.String[] getTopics()>();
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String formatArray(java.lang.String[])>(v);
v[1] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Last Activated</td><td>%s</td><td>Topics</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[2];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getLastFinishedJobTime()>();
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String formatDate(long)>(v);
v[0] = v;
v = interfaceinvoke v.<org.apache.sling.event.jobs.QueueConfiguration: int getMaxParallel()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Last Finished</td><td>%s</td><td>Max Parallel</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[2];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getNumberOfQueuedJobs()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
v = interfaceinvoke v.<org.apache.sling.event.jobs.QueueConfiguration: int getMaxRetries()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Queued Jobs</td><td>%s</td><td>Max Retries</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[2];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getNumberOfActiveJobs()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
v = interfaceinvoke v.<org.apache.sling.event.jobs.QueueConfiguration: long getRetryDelayInMs()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[1] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Active Jobs</td><td>%s</td><td>Retry Delay</td><td>%s ms</td></tr>", v);
v = newarray (java.lang.Object)[2];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getNumberOfJobs()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
v = interfaceinvoke v.<org.apache.sling.event.jobs.QueueConfiguration: org.apache.sling.event.jobs.QueueConfiguration$ThreadPriority getThreadPriority()>();
v[1] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Jobs</td><td>%s</td><td>Priority</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getNumberOfFinishedJobs()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Finished Jobs</td><td>%s</td><td colspan=\'2\'>&nbsp</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getNumberOfFailedJobs()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Failed Jobs</td><td>%s</td><td colspan=\'2\'>&nbsp</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getNumberOfCancelledJobs()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Cancelled Jobs</td><td>%s</td><td colspan=\'2\'>&nbsp</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getNumberOfProcessedJobs()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Processed Jobs</td><td>%s</td><td colspan=\'2\'>&nbsp</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getAverageProcessingTime()>();
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String formatTime(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Average Processing Time</td><td>%s</td><td colspan=\'2\'>&nbsp</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Statistics: long getAverageWaitingTime()>();
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String formatTime(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Average Waiting Time</td><td>%s</td><td colspan=\'2\'>&nbsp</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.Queue: java.lang.String getStateInfo()>();
v = staticinvoke <org.apache.sling.api.request.ResponseUtil: java.lang.String escapeXml(java.lang.String)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Status Info</td><td colspan=\'3\'>%s</td></tr>", v);
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("</tbody></table>");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<br/>");
goto label;
label:
if v == 0 goto label;
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<p>No active queues.</p>");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<br/>");
label:
v = v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: org.apache.sling.event.jobs.JobManager jobManager>;
v = interfaceinvoke v.<org.apache.sling.event.jobs.JobManager: java.lang.Iterable getTopicStatistics()>();
v = interfaceinvoke v.<java.lang.Iterable: 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()>();
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<table class=\'nicetable\'><tbody>");
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.TopicStatistics: java.lang.String getTopic()>();
v = staticinvoke <org.apache.sling.api.request.ResponseUtil: java.lang.String escapeXml(java.lang.String)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><th colspan=\'2\'>Topic Statistics: %s</th></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.TopicStatistics: long getLastActivatedJobTime()>();
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String formatDate(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Last Activated</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.TopicStatistics: long getLastFinishedJobTime()>();
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String formatDate(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Last Finished</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.TopicStatistics: long getNumberOfFinishedJobs()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Finished Jobs</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.TopicStatistics: long getNumberOfFailedJobs()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Failed Jobs</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.TopicStatistics: long getNumberOfCancelledJobs()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Cancelled Jobs</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.TopicStatistics: long getNumberOfProcessedJobs()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Processed Jobs</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.TopicStatistics: long getAverageProcessingTime()>();
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String formatTime(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Average Processing Time</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.sling.event.jobs.TopicStatistics: long getAverageWaitingTime()>();
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String formatTime(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Average Waiting Time</td><td>%s</td></tr>", v);
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("</tbody></table>");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<br/>");
goto label;
label:
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<p class=\'statline\'>Apache Sling Job Handling - Job Queue Configurations</p>");
v = v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: 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 = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.QueueConfigurationManager: org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration getMainQueueConfiguration()>();
specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: void printQueueConfiguration(javax.servlet.http.HttpServletRequest,java.io.PrintWriter,org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration)>(v, v, v);
v = v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: 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 = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.QueueConfigurationManager: org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration[] getConfigurations()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: void printQueueConfiguration(javax.servlet.http.HttpServletRequest,java.io.PrintWriter,org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration)>(v, v, v);
v = v + 1;
goto label;
label:
return;
}
private void printQueueConfiguration(javax.servlet.http.HttpServletRequest, java.io.PrintWriter, org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration)
{
java.lang.Integer v, v, v;
java.lang.Long v;
boolean v;
org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration v;
java.io.PrintWriter v;
java.lang.Object[] v, v, v, v, v, v, v, v, v, v;
java.lang.String[] v;
long v;
org.apache.sling.event.jobs.QueueConfiguration$ThreadPriority v;
javax.servlet.http.HttpServletRequest v;
int v, v, v;
java.lang.Boolean v;
java.lang.String v, v, v, v, v, v, v, v;
org.apache.sling.event.impl.jobs.console.WebConsolePlugin v;
org.apache.sling.event.jobs.QueueConfiguration$Type v;
v := @this: org.apache.sling.event.impl.jobs.console.WebConsolePlugin;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: java.io.PrintWriter;
v := @parameter: org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration;
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<div class=\'ui-widget-header ui-corner-top buttonGroup\'>");
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration: java.lang.String getName()>();
v = staticinvoke <org.apache.sling.api.request.ResponseUtil: java.lang.String escapeXml(java.lang.String)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<span style=\'float: left; margin-left: 1em\'>Job Queue Configuration: %s</span>%n", v);
v = newarray (java.lang.Object)[3];
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getContextPath()>();
v[0] = v;
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getServletPath()>();
v[1] = v;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration: java.lang.String getPid()>();
v[2] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<button id=\'edit\' class=\'ui-state-default ui-corner-all\' onclick=\'javascript:window.location=\"%s%s/configMgr/%s\";\'>Edit</button>", v);
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration: java.lang.String getName()>();
specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: void printForm(java.io.PrintWriter,java.lang.String,java.lang.String,java.lang.String)>(v, v, "Test", "test");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("</div>");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<table class=\'nicetable\'><tbody>");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<tr><th colspan=\'2\'>Configuration</th></tr>");
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration: boolean isValid()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Valid</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration: org.apache.sling.event.jobs.QueueConfiguration$Type getType()>();
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String formatType(org.apache.sling.event.jobs.QueueConfiguration$Type)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Type</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration: java.lang.String[] getTopics()>();
v = specialinvoke v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.lang.String formatArray(java.lang.String[])>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Topics</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration: int getMaxParallel()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Max Parallel</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration: int getMaxRetries()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Max Retries</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration: long getRetryDelayInMs()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Retry Delay</td><td>%s ms</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration: org.apache.sling.event.jobs.QueueConfiguration$ThreadPriority getThreadPriority()>();
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Priority</td><td>%s</td></tr>", v);
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration: int getRanking()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<tr><td>Ranking</td><td>%s</td></tr>", v);
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("</tbody></table>");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>("<br/>");
return;
}
private java.lang.String formatArray(java.lang.String[])
{
org.apache.sling.event.impl.jobs.console.WebConsolePlugin v;
java.lang.String[] v;
int v, v, v;
java.lang.StringBuilder v;
java.lang.String v, v, v;
boolean v;
v := @this: org.apache.sling.event.impl.jobs.console.WebConsolePlugin;
v := @parameter: java.lang.String[];
if v == null goto label;
v = lengthof v;
if v != 0 goto label;
label:
return "";
label:
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = 1;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
if v != 0 goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(10);
label:
v = 0;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = v + 1;
goto label;
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
v = staticinvoke <org.apache.sling.api.request.ResponseUtil: java.lang.String escapeXml(java.lang.String)>(v);
return v;
}
private java.lang.String formatType(org.apache.sling.event.jobs.QueueConfiguration$Type)
{
int[] v;
org.apache.sling.event.impl.jobs.console.WebConsolePlugin v;
org.apache.sling.event.jobs.QueueConfiguration$Type v;
int v, v;
java.lang.String v;
v := @this: org.apache.sling.event.impl.jobs.console.WebConsolePlugin;
v := @parameter: org.apache.sling.event.jobs.QueueConfiguration$Type;
v = <org.apache.sling.event.impl.jobs.console.WebConsolePlugin$1: int[] $SwitchMap$org$apache$sling$event$jobs$QueueConfiguration$Type>;
v = virtualinvoke v.<org.apache.sling.event.jobs.QueueConfiguration$Type: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
default: goto label;
};
label:
return "Ordered";
label:
return "Topic Round Robin";
label:
return "Parallel";
label:
v = virtualinvoke v.<org.apache.sling.event.jobs.QueueConfiguration$Type: java.lang.String toString()>();
return v;
}
private synchronized java.lang.String formatDate(long)
{
byte v;
org.apache.sling.event.impl.jobs.console.WebConsolePlugin v;
java.util.Date v;
long v;
java.lang.String v;
java.text.DateFormat v;
v := @this: org.apache.sling.event.impl.jobs.console.WebConsolePlugin;
v := @parameter: long;
v = v cmp -1L;
if v != 0 goto label;
return "-";
label:
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>(long)>(v);
v = v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: java.text.DateFormat dateFormat>;
v = virtualinvoke v.<java.text.DateFormat: java.lang.String format(java.util.Date)>(v);
return v;
}
private java.lang.String formatTime(long)
{
org.apache.sling.event.impl.jobs.console.WebConsolePlugin v;
long v, v, v, v, v, v, v, v;
byte v, v, v;
java.lang.String v, v, v;
v := @this: org.apache.sling.event.impl.jobs.console.WebConsolePlugin;
v := @parameter: long;
v = v cmp 0L;
if v != 0 goto label;
return "-";
label:
v = v cmp 1000L;
if v >= 0 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(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[])>("\u ms");
return v;
label:
v = v cmp 60000L;
if v >= 0 goto label;
v = v / 1000L;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(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[])>("\u secs");
return v;
label:
v = v / 1000L;
v = v / 60L;
v = v * 1000L;
v = v * 60L;
v = v - v;
v = v / 1000L;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long,long)>(v, 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[])>("\u min \u secs");
return v;
}
private void printForm(java.io.PrintWriter, java.lang.String, java.lang.String, java.lang.String)
{
java.io.PrintWriter v;
java.lang.Object[] v;
org.apache.sling.event.impl.jobs.console.WebConsolePlugin v;
java.lang.String v, v, v, v, v, v;
v := @this: org.apache.sling.event.impl.jobs.console.WebConsolePlugin;
v := @parameter: java.io.PrintWriter;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = newarray (java.lang.Object)[3];
v = staticinvoke <org.apache.sling.api.request.ResponseUtil: java.lang.String escapeXml(java.lang.String)>(v);
v[0] = v;
if v == null goto label;
v = staticinvoke <org.apache.sling.api.request.ResponseUtil: java.lang.String escapeXml(java.lang.String)>(v);
goto label;
label:
v = "";
label:
v[1] = v;
v = staticinvoke <org.apache.sling.api.request.ResponseUtil: java.lang.String escapeXml(java.lang.String)>(v);
v[2] = v;
virtualinvoke v.<java.io.PrintWriter: java.io.PrintWriter printf(java.lang.String,java.lang.Object[])>("<button class=\'ui-state-default ui-corner-all\' onclick=\'javascript:eventingsubmit(\"%s\", \"%s\");\'>%s</button>", v);
return;
}
public org.apache.sling.event.jobs.consumer.JobConsumer$JobResult process(org.apache.sling.event.jobs.Job)
{
org.apache.sling.event.jobs.consumer.JobConsumer$JobResult v;
org.slf4j.Logger v;
org.apache.sling.event.impl.jobs.console.WebConsolePlugin v;
org.apache.sling.event.jobs.Job v;
java.lang.String v;
v := @this: org.apache.sling.event.impl.jobs.console.WebConsolePlugin;
v := @parameter: org.apache.sling.event.jobs.Job;
v = v.<org.apache.sling.event.impl.jobs.console.WebConsolePlugin: org.slf4j.Logger logger>;
v = interfaceinvoke v.<org.apache.sling.event.jobs.Job: java.lang.String getTopic()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Received test job {}", v);
v = <org.apache.sling.event.jobs.consumer.JobConsumer$JobResult: org.apache.sling.event.jobs.consumer.JobConsumer$JobResult OK>;
return v;
}
}