org.apache.catalina.tribes.group.interceptors
public class MessageDispatch15Interceptor extends MessageDispatchInterceptor
Version: 1.0
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() |