org.springframework.messaging.simp.config

Class TaskExecutorRegistration

java.lang.Object

org.springframework.messaging.simp.config.TaskExecutorRegistration

public class TaskExecutorRegistration
extends Object

A registration class for customizing the properties of ThreadPoolTaskExecutor.

Since:

4.0

Author:

Rossen Stoyanchev

Constructor Summary

Constructors

Constructor and Description
TaskExecutorRegistration()

Method Summary

Modifier and Type	Method and Description
TaskExecutorRegistration	corePoolSize(int corePoolSize) Set the ThreadPoolExecutor's core pool size.
protected ThreadPoolTaskExecutor	getTaskExecutor()
TaskExecutorRegistration	keepAliveSeconds(int keepAliveSeconds) Set the ThreadPoolExecutor's keep-alive seconds.
TaskExecutorRegistration	maxPoolSize(int maxPoolSize) Set the ThreadPoolExecutor's maximum pool size.
TaskExecutorRegistration	queueCapacity(int queueCapacity) Set the capacity for the ThreadPoolExecutor's BlockingQueue.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TaskExecutorRegistration

public TaskExecutorRegistration()

Method Detail

corePoolSize

public TaskExecutorRegistration corePoolSize(int corePoolSize)

Set the ThreadPoolExecutor's core pool size. Default is 1.

maxPoolSize

public TaskExecutorRegistration maxPoolSize(int maxPoolSize)

Set the ThreadPoolExecutor's maximum pool size. Default is Integer.MAX_VALUE.

keepAliveSeconds

public TaskExecutorRegistration keepAliveSeconds(int keepAliveSeconds)

Set the ThreadPoolExecutor's keep-alive seconds. Default is 60.

queueCapacity

public TaskExecutorRegistration queueCapacity(int queueCapacity)

Set the capacity for the ThreadPoolExecutor's BlockingQueue. Default is Integer.MAX_VALUE.

Any positive value will lead to a LinkedBlockingQueue instance; any other value will lead to a SynchronousQueue instance.

See Also:

LinkedBlockingQueue, SynchronousQueue

getTaskExecutor

protected ThreadPoolTaskExecutor getTaskExecutor()