public class org.springframework.messaging.simp.config.TaskExecutorRegistration extends java.lang.Object
{
private final org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor;
private java.lang.Integer corePoolSize;
private java.lang.Integer maxPoolSize;
private java.lang.Integer keepAliveSeconds;
private java.lang.Integer queueCapacity;
public void <init>()
{
org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor v, v, v;
org.springframework.messaging.simp.config.TaskExecutorRegistration v;
java.lang.Runtime v;
int v, v;
v := @this: org.springframework.messaging.simp.config.TaskExecutorRegistration;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
specialinvoke v.<org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor: void <init>()>();
v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor> = v;
v = v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor>;
v = staticinvoke <java.lang.Runtime: java.lang.Runtime getRuntime()>();
v = virtualinvoke v.<java.lang.Runtime: int availableProcessors()>();
v = v * 2;
virtualinvoke v.<org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor: void setCorePoolSize(int)>(v);
v = v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor>;
virtualinvoke v.<org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor: void setAllowCoreThreadTimeOut(boolean)>(1);
return;
}
public void <init>(org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor)
{
org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor v;
org.springframework.messaging.simp.config.TaskExecutorRegistration v;
v := @this: org.springframework.messaging.simp.config.TaskExecutorRegistration;
v := @parameter: org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
specialinvoke v.<java.lang.Object: void <init>()>();
staticinvoke <org.springframework.util.Assert: void notNull(java.lang.Object,java.lang.String)>(v, "ThreadPoolTaskExecutor must not be null");
v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor> = v;
return;
}
public org.springframework.messaging.simp.config.TaskExecutorRegistration corePoolSize(int)
{
int v;
java.lang.Integer v;
org.springframework.messaging.simp.config.TaskExecutorRegistration v;
v := @this: org.springframework.messaging.simp.config.TaskExecutorRegistration;
v := @parameter: int;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: java.lang.Integer corePoolSize> = v;
return v;
}
public org.springframework.messaging.simp.config.TaskExecutorRegistration maxPoolSize(int)
{
int v;
java.lang.Integer v;
org.springframework.messaging.simp.config.TaskExecutorRegistration v;
v := @this: org.springframework.messaging.simp.config.TaskExecutorRegistration;
v := @parameter: int;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: java.lang.Integer maxPoolSize> = v;
return v;
}
public org.springframework.messaging.simp.config.TaskExecutorRegistration keepAliveSeconds(int)
{
int v;
java.lang.Integer v;
org.springframework.messaging.simp.config.TaskExecutorRegistration v;
v := @this: org.springframework.messaging.simp.config.TaskExecutorRegistration;
v := @parameter: int;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: java.lang.Integer keepAliveSeconds> = v;
return v;
}
public org.springframework.messaging.simp.config.TaskExecutorRegistration queueCapacity(int)
{
int v;
java.lang.Integer v;
org.springframework.messaging.simp.config.TaskExecutorRegistration v;
v := @this: org.springframework.messaging.simp.config.TaskExecutorRegistration;
v := @parameter: int;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: java.lang.Integer queueCapacity> = v;
return v;
}
protected org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor getTaskExecutor()
{
org.springframework.messaging.simp.config.TaskExecutorRegistration v;
java.lang.Integer v, v, v, v, v, v, v, v;
int v, v, v, v;
org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor v, v, v, v, v;
v := @this: org.springframework.messaging.simp.config.TaskExecutorRegistration;
v = v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: java.lang.Integer corePoolSize>;
if v == null goto label;
v = v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor>;
v = v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: java.lang.Integer corePoolSize>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor: void setCorePoolSize(int)>(v);
label:
v = v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: java.lang.Integer maxPoolSize>;
if v == null goto label;
v = v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor>;
v = v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: java.lang.Integer maxPoolSize>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor: void setMaxPoolSize(int)>(v);
label:
v = v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: java.lang.Integer keepAliveSeconds>;
if v == null goto label;
v = v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor>;
v = v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: java.lang.Integer keepAliveSeconds>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor: void setKeepAliveSeconds(int)>(v);
label:
v = v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: java.lang.Integer queueCapacity>;
if v == null goto label;
v = v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor>;
v = v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: java.lang.Integer queueCapacity>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor: void setQueueCapacity(int)>(v);
label:
v = v.<org.springframework.messaging.simp.config.TaskExecutorRegistration: org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor>;
return v;
}
}