org.springframework.integration.endpoint
Class ConcurrencyPolicy

java.lang.Object
  org.springframework.integration.endpoint.ConcurrencyPolicy

public class ConcurrencyPolicy
extends java.lang.Object

Metadata for configuring a pool of concurrent threads.

Author:

Mark Fisher

Field Summary

private int	coreSize
static int	DEFAULT_CORE_SIZE
static int	DEFAULT_KEEP_ALIVE_SECONDS
static int	DEFAULT_MAX_SIZE
static int	DEFAULT_QUEUE_CAPACITY
private int	keepAliveSeconds
private int	maxSize
private int	queueCapacity

Constructor Summary

ConcurrencyPolicy()

ConcurrencyPolicy(int coreSize, int maxSize)

Method Summary

int	getCoreSize()
int	getKeepAliveSeconds()
int	getMaxSize()
int	getQueueCapacity()
void	setCoreSize(int coreSize)
void	setKeepAliveSeconds(int keepAliveSeconds)
void	setMaxSize(int maxSize)
void	setQueueCapacity(int queueCapacity)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_CORE_SIZE

public static final int DEFAULT_CORE_SIZE

See Also:

Constant Field Values

DEFAULT_MAX_SIZE

public static final int DEFAULT_MAX_SIZE

See Also:

Constant Field Values

DEFAULT_QUEUE_CAPACITY

public static final int DEFAULT_QUEUE_CAPACITY

See Also:

Constant Field Values

DEFAULT_KEEP_ALIVE_SECONDS

public static final int DEFAULT_KEEP_ALIVE_SECONDS

See Also:

Constant Field Values

coreSize

private int coreSize

maxSize

private int maxSize

queueCapacity

private int queueCapacity

keepAliveSeconds

private int keepAliveSeconds

Constructor Detail

ConcurrencyPolicy

public ConcurrencyPolicy()

ConcurrencyPolicy

public ConcurrencyPolicy(int coreSize,
                         int maxSize)

Method Detail

getCoreSize

public int getCoreSize()

setCoreSize

public void setCoreSize(int coreSize)

getMaxSize

public int getMaxSize()

setMaxSize

public void setMaxSize(int maxSize)

getQueueCapacity

public int getQueueCapacity()

setQueueCapacity

public void setQueueCapacity(int queueCapacity)

getKeepAliveSeconds

public int getKeepAliveSeconds()

setKeepAliveSeconds

public void setKeepAliveSeconds(int keepAliveSeconds)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object