org.springframework.integration.endpoint
Class ConcurrencyPolicy

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

All Implemented Interfaces:

EndpointPolicy

public class ConcurrencyPolicy
extends java.lang.Object
implements EndpointPolicy

Metadata for configuring a pool of concurrent threads.

Author:

Mark Fisher

Field Summary

static int	DEFAULT_CORE_SIZE
static int	DEFAULT_KEEP_ALIVE_SECONDS
static int	DEFAULT_MAX_SIZE
static int	DEFAULT_QUEUE_CAPACITY

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, 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

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)