public class org.apache.camel.spring.util.CamelThreadPoolTaskScheduler extends org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler
{
private static final long serialVersionUID;
private final org.apache.camel.CamelContext camelContext;
private final java.lang.Object source;
private final java.lang.String name;
public void <init>(org.apache.camel.CamelContext, java.lang.Object, java.lang.String)
{
org.apache.camel.CamelContext v;
java.lang.Object v;
java.lang.String v;
org.apache.camel.spring.util.CamelThreadPoolTaskScheduler v;
v := @this: org.apache.camel.spring.util.CamelThreadPoolTaskScheduler;
v := @parameter: org.apache.camel.CamelContext;
v := @parameter: java.lang.Object;
v := @parameter: java.lang.String;
specialinvoke v.<org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler: void <init>()>();
v.<org.apache.camel.spring.util.CamelThreadPoolTaskScheduler: org.apache.camel.CamelContext camelContext> = v;
v.<org.apache.camel.spring.util.CamelThreadPoolTaskScheduler: java.lang.Object source> = v;
v.<org.apache.camel.spring.util.CamelThreadPoolTaskScheduler: java.lang.String name> = v;
return;
}
protected java.util.concurrent.ScheduledExecutorService createExecutor(int, java.util.concurrent.ThreadFactory, java.util.concurrent.RejectedExecutionHandler)
{
org.apache.camel.CamelContext v;
org.apache.camel.spring.util.CamelThreadPoolTaskScheduler v;
java.util.concurrent.RejectedExecutionHandler v;
int v;
java.util.concurrent.ScheduledExecutorService v;
org.apache.camel.spi.ExecutorServiceManager v;
java.lang.Object v;
java.lang.String v;
java.util.concurrent.ThreadFactory v;
v := @this: org.apache.camel.spring.util.CamelThreadPoolTaskScheduler;
v := @parameter: int;
v := @parameter: java.util.concurrent.ThreadFactory;
v := @parameter: java.util.concurrent.RejectedExecutionHandler;
v = v.<org.apache.camel.spring.util.CamelThreadPoolTaskScheduler: org.apache.camel.CamelContext camelContext>;
v = interfaceinvoke v.<org.apache.camel.CamelContext: org.apache.camel.spi.ExecutorServiceManager getExecutorServiceManager()>();
v = v.<org.apache.camel.spring.util.CamelThreadPoolTaskScheduler: java.lang.Object source>;
v = v.<org.apache.camel.spring.util.CamelThreadPoolTaskScheduler: java.lang.String name>;
v = interfaceinvoke v.<org.apache.camel.spi.ExecutorServiceManager: java.util.concurrent.ScheduledExecutorService newScheduledThreadPool(java.lang.Object,java.lang.String,int)>(v, v, v);
return v;
}
public void shutdown()
{
org.apache.camel.CamelContext v;
java.util.concurrent.ScheduledExecutorService v;
org.apache.camel.spi.ExecutorServiceManager v;
org.apache.camel.spring.util.CamelThreadPoolTaskScheduler v;
v := @this: org.apache.camel.spring.util.CamelThreadPoolTaskScheduler;
v = v.<org.apache.camel.spring.util.CamelThreadPoolTaskScheduler: org.apache.camel.CamelContext camelContext>;
v = interfaceinvoke v.<org.apache.camel.CamelContext: org.apache.camel.spi.ExecutorServiceManager getExecutorServiceManager()>();
v = virtualinvoke v.<org.apache.camel.spring.util.CamelThreadPoolTaskScheduler: java.util.concurrent.ScheduledExecutorService getScheduledExecutor()>();
interfaceinvoke v.<org.apache.camel.spi.ExecutorServiceManager: java.util.List shutdownNow(java.util.concurrent.ExecutorService)>(v);
return;
}
}