org.springframework.integration.endpoint
Class ConcurrencyPolicy

java.lang.Object
  extended by 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)