org.apache.catalina.tribes.group.interceptors

Class MessageDispatch15Interceptor

public class MessageDispatch15Interceptor extends MessageDispatchInterceptor

Same implementation as the MessageDispatchInterceptor except is ues an atomic long for the currentSize calculation and uses a thread pool for message sending.

Version: 1.0

Author: Filip Hanik

Field Summary
protected AtomicLong	currentSize
protected ThreadPoolExecutor	executor
protected long	keepAliveTime
protected int	maxSpareThreads
protected int	maxThreads
protected LinkedBlockingQueue<Runnable>	runnablequeue

Method Summary
long	addAndGetCurrentSize(long inc)
boolean	addToQueue(ChannelMessage msg, Member[] destination, InterceptorPayload payload)
long	getCurrentSize()
long	getKeepAliveTime()
int	getMaxSpareThreads()
int	getMaxThreads()
LinkObject	removeFromQueue()
long	setAndGetCurrentSize(long value)
void	setKeepAliveTime(long keepAliveTime)
void	setMaxSpareThreads(int maxSpareThreads)
void	setMaxThreads(int maxThreads)
void	startQueue()
void	stopQueue()