public class org.apache.camel.management.mbean.ManagedThreads extends org.apache.camel.management.mbean.ManagedProcessor implements org.apache.camel.api.management.mbean.ManagedThreadsMBean
{
private final org.apache.camel.processor.ThreadsProcessor processor;
public void <init>(org.apache.camel.CamelContext, org.apache.camel.processor.ThreadsProcessor, org.apache.camel.model.ProcessorDefinition)
{
org.apache.camel.CamelContext v;
org.apache.camel.model.ProcessorDefinition v;
org.apache.camel.processor.ThreadsProcessor v;
org.apache.camel.management.mbean.ManagedThreads v;
v := @this: org.apache.camel.management.mbean.ManagedThreads;
v := @parameter: org.apache.camel.CamelContext;
v := @parameter: org.apache.camel.processor.ThreadsProcessor;
v := @parameter: org.apache.camel.model.ProcessorDefinition;
specialinvoke v.<org.apache.camel.management.mbean.ManagedProcessor: void <init>(org.apache.camel.CamelContext,org.apache.camel.Processor,org.apache.camel.model.ProcessorDefinition)>(v, v, v);
v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor> = v;
return;
}
public java.lang.Boolean isCallerRunsWhenRejected()
{
org.apache.camel.processor.ThreadsProcessor v;
org.apache.camel.management.mbean.ManagedThreads v;
java.lang.Boolean v;
java.lang.String v, v;
java.util.concurrent.ExecutorService v;
boolean v, v;
v := @this: org.apache.camel.management.mbean.ManagedThreads;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = v instanceof java.util.concurrent.ThreadPoolExecutor;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedThreads: java.lang.String getRejectedPolicy()>();
v = "CallerRuns";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
return v;
label:
return null;
}
public java.lang.String getRejectedPolicy()
{
org.apache.camel.processor.ThreadsProcessor v, v;
org.apache.camel.management.mbean.ManagedThreads v;
java.util.concurrent.RejectedExecutionHandler v;
java.lang.String v;
java.util.concurrent.ExecutorService v, v;
boolean v;
v := @this: org.apache.camel.management.mbean.ManagedThreads;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = v instanceof java.util.concurrent.ThreadPoolExecutor;
if v == 0 goto label;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: java.util.concurrent.RejectedExecutionHandler getRejectedExecutionHandler()>();
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
return v;
label:
return null;
}
public int getCorePoolSize()
{
org.apache.camel.processor.ThreadsProcessor v, v;
int v;
java.util.concurrent.ExecutorService v, v;
org.apache.camel.management.mbean.ManagedThreads v;
boolean v;
v := @this: org.apache.camel.management.mbean.ManagedThreads;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = v instanceof java.util.concurrent.ThreadPoolExecutor;
if v == 0 goto label;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: int getCorePoolSize()>();
return v;
label:
return 0;
}
public int getPoolSize()
{
org.apache.camel.processor.ThreadsProcessor v, v;
int v;
java.util.concurrent.ExecutorService v, v;
org.apache.camel.management.mbean.ManagedThreads v;
boolean v;
v := @this: org.apache.camel.management.mbean.ManagedThreads;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = v instanceof java.util.concurrent.ThreadPoolExecutor;
if v == 0 goto label;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: int getPoolSize()>();
return v;
label:
return 0;
}
public int getMaximumPoolSize()
{
org.apache.camel.processor.ThreadsProcessor v, v;
int v;
java.util.concurrent.ExecutorService v, v;
org.apache.camel.management.mbean.ManagedThreads v;
boolean v;
v := @this: org.apache.camel.management.mbean.ManagedThreads;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = v instanceof java.util.concurrent.ThreadPoolExecutor;
if v == 0 goto label;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: int getMaximumPoolSize()>();
return v;
label:
return 0;
}
public int getLargestPoolSize()
{
org.apache.camel.processor.ThreadsProcessor v, v;
int v;
java.util.concurrent.ExecutorService v, v;
org.apache.camel.management.mbean.ManagedThreads v;
boolean v;
v := @this: org.apache.camel.management.mbean.ManagedThreads;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = v instanceof java.util.concurrent.ThreadPoolExecutor;
if v == 0 goto label;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: int getLargestPoolSize()>();
return v;
label:
return 0;
}
public int getActiveCount()
{
org.apache.camel.processor.ThreadsProcessor v, v;
int v;
java.util.concurrent.ExecutorService v, v;
org.apache.camel.management.mbean.ManagedThreads v;
boolean v;
v := @this: org.apache.camel.management.mbean.ManagedThreads;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = v instanceof java.util.concurrent.ThreadPoolExecutor;
if v == 0 goto label;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: int getActiveCount()>();
return v;
label:
return 0;
}
public long getTaskCount()
{
org.apache.camel.processor.ThreadsProcessor v, v;
long v;
java.util.concurrent.ExecutorService v, v;
org.apache.camel.management.mbean.ManagedThreads v;
boolean v;
v := @this: org.apache.camel.management.mbean.ManagedThreads;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = v instanceof java.util.concurrent.ThreadPoolExecutor;
if v == 0 goto label;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: long getTaskCount()>();
return v;
label:
return 0L;
}
public long getCompletedTaskCount()
{
org.apache.camel.processor.ThreadsProcessor v, v;
long v;
java.util.concurrent.ExecutorService v, v;
org.apache.camel.management.mbean.ManagedThreads v;
boolean v;
v := @this: org.apache.camel.management.mbean.ManagedThreads;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = v instanceof java.util.concurrent.ThreadPoolExecutor;
if v == 0 goto label;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: long getCompletedTaskCount()>();
return v;
label:
return 0L;
}
public long getTaskQueueSize()
{
org.apache.camel.processor.ThreadsProcessor v, v;
java.util.concurrent.BlockingQueue v;
org.apache.camel.management.mbean.ManagedThreads v;
int v;
java.util.concurrent.ExecutorService v, v;
boolean v;
v := @this: org.apache.camel.management.mbean.ManagedThreads;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = v instanceof java.util.concurrent.ThreadPoolExecutor;
if v == 0 goto label;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: java.util.concurrent.BlockingQueue getQueue()>();
if v == null goto label;
v = interfaceinvoke v.<java.util.concurrent.BlockingQueue: int size()>();
goto label;
label:
v = 0L;
label:
return v;
label:
return 0L;
}
public long getKeepAliveTime()
{
org.apache.camel.processor.ThreadsProcessor v, v;
long v;
org.apache.camel.management.mbean.ManagedThreads v;
java.util.concurrent.TimeUnit v;
java.util.concurrent.ExecutorService v, v;
boolean v;
v := @this: org.apache.camel.management.mbean.ManagedThreads;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = v instanceof java.util.concurrent.ThreadPoolExecutor;
if v == 0 goto label;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: long getKeepAliveTime(java.util.concurrent.TimeUnit)>(v);
return v;
label:
return 0L;
}
public boolean isAllowCoreThreadTimeout()
{
org.apache.camel.processor.ThreadsProcessor v, v;
java.util.concurrent.ExecutorService v, v;
org.apache.camel.management.mbean.ManagedThreads v;
boolean v, v;
v := @this: org.apache.camel.management.mbean.ManagedThreads;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = v instanceof java.util.concurrent.ThreadPoolExecutor;
if v == 0 goto label;
v = v.<org.apache.camel.management.mbean.ManagedThreads: org.apache.camel.processor.ThreadsProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.ThreadsProcessor: java.util.concurrent.ExecutorService getExecutorService()>();
v = virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: boolean allowsCoreThreadTimeOut()>();
return v;
label:
return 0;
}
}