org.apache.catalina.tribes.group.interceptors
public class MessageDispatchInterceptor extends ChannelInterceptorBase implements Runnable
Channel.SEND_OPTIONS_ASYNCHRONOUS
flag to be set, if it is, it will queue the message for delivery and immediately return to the sender.
Version: 1.0
| Field Summary | |
|---|---|
| protected boolean | alwaysSend |
| protected long | currentSize |
| protected static Log | log |
| protected long | maxQueueSize |
| protected Thread | msgDispatchThread |
| protected FastQueue | queue |
| protected boolean | run |
| protected boolean | useDeepClone |
| Constructor Summary | |
|---|---|
| MessageDispatchInterceptor() | |
| Method Summary | |
|---|---|
| long | addAndGetCurrentSize(long inc) |
| boolean | addToQueue(ChannelMessage msg, Member[] destination, InterceptorPayload payload) |
| long | getCurrentSize() |
| long | getMaxQueueSize() |
| boolean | getUseDeepClone() |
| boolean | isAlwaysSend() |
| LinkObject | removeFromQueue() |
| void | run() |
| protected LinkObject | sendAsyncData(LinkObject link) |
| void | sendMessage(Member[] destination, ChannelMessage msg, InterceptorPayload payload) |
| void | setAlwaysSend(boolean alwaysSend) |
| long | setAndGetCurrentSize(long value) |
| void | setMaxQueueSize(long maxQueueSize) |
| void | setOptionFlag(int flag) |
| void | setUseDeepClone(boolean useDeepClone) |
| void | start(int svc) |
| void | startQueue() |
| void | stop(int svc) |
| void | stopQueue() |